data
Confluent Cloud CLI for Headless Automation
Use the Confluent Cloud CLI for headless automation with headless JSON commands, schema discovery, credentials, and permission controls.
7 functions 6 read 1 write API token auth
Confluent Cloud CLI for Headless Automation
Use KosmoKrator as a non-interactive integration runtime for local automations and wrappers.
Use headless automation when another tool needs a stable local command surface. The Confluent Cloud CLI uses the same integration registry as the TUI, Lua runtime, and MCP gateway, but returns predictable command output for automation.
Command Shape
# Confluent Cloud CLI for Headless Automation
kosmokrator integrations:configure confluent --set api_token="$CONFLUENT_API_TOKEN" --enable --read allow --write ask --json
kosmo integrations:call confluent.confluent_list_topics '{"cluster_id":"example_cluster_id"}' --json Discovery Before Execution
Agents and scripts can inspect Confluent Cloud docs and schemas before choosing a function.
kosmo integrations:docs confluent --json
kosmo integrations:docs confluent.confluent_list_topics --json
kosmo integrations:schema confluent.confluent_list_topics --json
kosmo integrations:search "Confluent Cloud" --json
kosmo integrations:list --json Useful Confluent Cloud CLI Functions
| Function | Type | Parameters | Description |
|---|---|---|---|
confluent.confluent_list_topics | Read | cluster_id | List Kafka topics in a Confluent cluster. Returns topic names, partition counts, replication factors, and status. |
confluent.confluent_get_topic | Read | topic_name, cluster_id | Get full details of a specific Kafka topic by name. Returns partition count, replication factor, and topic configuration. |
confluent.confluent_create_topic | Write | topic_name, partitions_count, replication_factor, configs, cluster_id | Create a new Kafka topic in a Confluent cluster. Specify the topic name, partition count, and optional replication factor and configs. |
confluent.confluent_list_clusters | Read | none | List Kafka clusters in your Confluent Cloud environment. Returns cluster IDs, names, types, and status. |
confluent.confluent_get_cluster | Read | cluster_id | Get details of a specific Kafka cluster. Returns broker count, controller info, and cluster configuration. |
confluent.confluent_list_environments | Read | none | List Confluent Cloud environments. Returns environment IDs, names, and associated cluster resources. |
confluent.confluent_get_current_user | Read | none | Get the currently authenticated Confluent Cloud user. Useful for verifying credentials and identifying the connected account. |
Automation Notes
- Use
--jsonfor machine-readable output. - Keep credentials out of argv by using environment variables or stored KosmoKrator configuration.
- Configure read/write policy before unattended runs; use
--forceonly for trusted automation. - Use the MCP gateway instead when the agent needs dynamic tool discovery inside a conversation.