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.

7 functions 6 read 1 write API token auth

Submit Apache Kafka feedback View package source

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.

Machine-Readable Metadata

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

Quick Links

Lua APIAgent-facing namespace and function reference. Apache Kafka CLIHeadless setup and direct function calls. Apache Kafka MCPMCP gateway setup for external clients. Submit feedbackReport missing tools, auth problems, wrong docs, or runtime issues. ContributeAdd tools or improve metadata in the integrations repo.

Apache Kafka MCP Client Matrix

Use these pages when a specific agent client or framework needs copy-pasteable MCP setup for Apache Kafka.

Apache Kafka CLI Matrix

Use these pages for direct Apache Kafka CLI workflows in scripts, CI, cron, and agent wrappers.

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

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.