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 MCP, CLI, and Lua Integration for AI Agents

Apache Kafka integration docs for AI agents: MCP gateway setup, Apache Kafka CLI commands, Lua API reference, credentials, and function schemas.

Apache Kafka for agents

Credentials can be configured manually in web or CLI hosts.

Use this integration from Lua code mode, the headless integrations CLI, or the KosmoKrator MCP gateway. The same package metadata powers all three surfaces.

Agent Surfaces

Apache Kafka CLIHeadless setup, JSON output, direct function calls. Apache Kafka MCPExpose selected tools to local MCP clients. Apache Kafka LuaAgent-facing namespace and Lua reference. FeedbackReport missing tools, auth issues, or bad metadata.

Machine-Readable Metadata

integration_slug: kafka
route_slug: kafka
package: kafka
auth_strategy: api_token
cli_setup_supported: true
cli_runtime_supported: true
mcp_gateway_supported: true
lua_supported: true

Function Catalog

Function	Type	Parameters	Description
`kafka.kafka_list_topics`	Read `read`	1	List Kafka topics in a cluster. Returns topic names, partition counts, replication factors, and status.
`kafka.kafka_get_topic`	Read `read`	2	Get full details of a specific Kafka topic by name. Returns partition count, replication factor, and topic configuration.
`kafka.kafka_create_topic`	Write `write`	5	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 `read`	0	List Kafka clusters in your Confluent Cloud environment. Returns cluster IDs, names, types, and status.
`kafka.kafka_get_cluster`	Read `read`	1	Get details of a specific Kafka cluster. Returns broker count, controller info, and cluster configuration.
`kafka.kafka_list_producers`	Read `read`	2	List producers for a specific Kafka topic. Returns producer IDs, client IDs, and connection details.
`kafka.kafka_get_current_user`	Read `read`	0	Get the currently authenticated Confluent Cloud user. Useful for verifying credentials and identifying the connected account.