MCP Kafka

mcp-kafka

A Model Context Protocol server for Apache Kafka. It lets an MCP-capable client (Claude Desktop, Claude Code, etc.) monitor and manage Kafka clusters — topics, partitions, configs, and consumer groups (including lag) — with behaviour controlled entirely by flags.

Safe by default: it starts read-only, can be scoped to an allowlist of topics, protects internal/critical topics from mutation, and gates destructive operations behind an explicit opt-in.

Features

• Monitoring — cluster/broker info, topic metadata and offsets, consumer groups, and per-partition + total consumer lag.
• Management — create topics, add partitions, alter topic configs, reset group offsets; delete topics/groups (admin).
• Access modes — read-only → read-write → admin, layered so a mode never exposes tools above its level.
• Security flags — topic allowlist, protected/internal topics, delete gating, dry-run, and JSON audit logging (see below).
• Auth — plaintext, TLS, and SASL (PLAIN / SCRAM-SHA-256 / SCRAM-SHA-512).

Security model

Tools

Read (read-only+): cluster_info, list_topics, describe_topic, topic_offsets, list_consumer_groups, describe_consumer_group (with lag)

Write (read-write+): create_topic, create_partitions, alter_topic_config, reset_consumer_group_offsets

Admin (admin): delete_topic, delete_consumer_group (both need KAFKA_ALLOW_DELETE)

Quickstart — add to your agent

Published on npm as @dockndevai/mcp-kafka. No clone or build needed — your MCP client runs it on demand with npx. Start in `read-only` mode; see .env.example for every variable and docs/CLIENTS.md for the full per-client guide.

Claude Code (CLI)

claude mcp add kafka -e KAFKA_BROKERS="localhost:9092" -e KAFKA_MODE="read-only" -- npx -y @dockndevai/mcp-kafka

Claude Desktop · Cursor · Windsurf — same block in claude_desktop_config.json, .cursor/mcp.json, or ~/.codeium/windsurf/mcp_config.json:

{

"mcpServers": { "kafka": { "command": "npx", "args": [ "-y", "@dockndevai/mcp-kafka" ], "env": { "KAFKA_BROKERS": "localhost:9092", "KAFKA_MODE": "read-only" } } } }

OpenAI Codex CLI — in ~/.codex/config.toml:

[mcp_servers.kafka]

command = "npx" args = ["-y", "@dockndevai/mcp-kafka"] env = { KAFKA_BROKERS = "localhost:9092", KAFKA_MODE = "read-only" }

VS Code (GitHub Copilot, Agent mode) — in .vscode/mcp.json:

{

"servers": { "kafka": { "type": "stdio", "command": "npx", "args": [ "-y", "@dockndevai/mcp-kafka" ], "env": { "KAFKA_BROKERS": "localhost:9092", "KAFKA_MODE": "read-only" } } } }

Example prompts

• *"Which consumer groups have the most lag right now?"*
• *"Describe the orders topic and show its offsets."*
• *"Create a topic events with 6 partitions and 7-day retention."* (needs read-write)

Run from source (development)

Prefer the published package above. To run from a clone:

npm install

npm run build node dist/index.js # with the environment variables set

Develop

npm run dev

npm test npm run typecheck

Publishing

This server ships a server.json for the official MCP registry and an mcpName for npm ownership validation. See [PUBLISHING.md](PUBLISHING.md) for publishing to npm and listing on the MCP registry, Smithery, Glama, Cursor, and PulseMCP.

License

MIT