Can I use Apache Kafka as a CLI?

Yes. KosmoKrator exposes a Apache Kafka CLI through kosmo integrations:call and the provider shortcut command. Commands can return JSON for scripts, CI, and coding agents.

Can I expose Apache Kafka through MCP?

Yes. The KosmoKrator MCP gateway can expose selected Apache Kafka tools to clients such as Claude Code, Cursor, Codex, and other MCP-compatible tools.

Where are Apache Kafka credentials stored?

Apache Kafka credentials are configured in KosmoKrator's local integration settings and reused by CLI, Lua, and MCP gateway surfaces.

Can I deny write access for Apache Kafka MCP tools?

Yes. Start the gateway with --write=deny for read-only clients, or use ask/allow only for trusted workspaces.

data

Apache Kafka CLI for Headless Automation

Use the Apache Kafka CLI for headless automation with headless JSON commands, schema discovery, credentials, and permission controls.

7 functions 6 read 1 write API token auth

Submit Apache Kafka feedback View package source

Apache Kafka 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 Apache Kafka CLI uses the same integration registry as the TUI, Lua runtime, and MCP gateway, but returns predictable command output for automation.

Command Shape

# Apache Kafka CLI for Headless Automation
kosmokrator integrations:configure kafka --set api_token="$KAFKA_API_TOKEN" --enable --read allow --write ask --json
kosmo integrations:call kafka.kafka_list_topics '{"cluster_id":"example_cluster_id"}' --json

Discovery Before Execution

Agents and scripts can inspect Apache Kafka docs and schemas before choosing a function.

kosmo integrations:docs kafka --json
kosmo integrations:docs kafka.kafka_list_topics --json
kosmo integrations:schema kafka.kafka_list_topics --json
kosmo integrations:search "Apache Kafka" --json
kosmo integrations:list --json

Useful Apache Kafka CLI Functions

Function	Type	Parameters	Description
`kafka.kafka_list_topics`	Read	cluster_id	List Kafka topics in a cluster. Returns topic names, partition counts, replication factors, and status.
`kafka.kafka_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.
`kafka.kafka_create_topic`	Write	topic_name, partitions_count, replication_factor, configs, cluster_id	Create a new Kafka topic in a cluster. Specify the topic name, partition count, and optional replication factor and configs.
`kafka.kafka_list_clusters`	Read	none	List Kafka clusters in your Confluent Cloud environment. Returns cluster IDs, names, types, and status.
`kafka.kafka_get_cluster`	Read	cluster_id	Get details of a specific Kafka cluster. Returns broker count, controller info, and cluster configuration.
`kafka.kafka_list_producers`	Read	topic_name, cluster_id	List producers for a specific Kafka topic. Returns producer IDs, client IDs, and connection details.
`kafka.kafka_get_current_user`	Read	none	Get the currently authenticated Confluent Cloud user. Useful for verifying credentials and identifying the connected account.

Automation Notes

Use --json for machine-readable output.
Keep credentials out of argv by using environment variables or stored KosmoKrator configuration.
Configure read/write policy before unattended runs; use --force only for trusted automation.
Use the MCP gateway instead when the agent needs dynamic tool discovery inside a conversation.

Related Apache Kafka CLI Pages

CI Apache Kafka CLI for CI. Cron Jobs Apache Kafka CLI for cron jobs. Shell Scripts Apache Kafka CLI for shell scripts. Coding Agents Apache Kafka CLI for coding agents.