Kafka MCP server

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+): clusterinfo, listtopics, describetopic, topicoffsets, listconsumergroups, describeconsumergroup (with lag)

Write (read-write+): createtopic, createpartitions, altertopicconfig, resetconsumergroup_offsets

Admin (admin): deletetopic, deleteconsumergroup (both need KAFKAALLOW_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 claudedesktopconfig.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:

Shortened. The full README is on GitHub.