mcp-kafka

一个面向 Apache Kafka 的 Model Context Protocol 服务器。它让支持 MCP 的客户端（Claude Desktop、Claude Code 等）能够监控和管理 Kafka 集群——主题、分区、配置和消费者组（含 consumer lag）——行为完全由标志（flag）控制。

默认安全：服务以只读模式启动，可通过主题 allowlist 限定范围，可让内部/关键主题不被修改，并且破坏性操作被放在显式 opt-in 之后。

功能

• 监控 — 集群/broker 信息、主题元数据和偏移量、消费者组，以及每个分区 + 总体统计的 consumer lag（消费滞后）。

• 管理 — 创建主题、增加分区、更改主题配置、重置消费组偏移量；删除主题/消费者组（admin 模式）。

• 访问模式 —- read-only → read-write → admin，分层设计，任何模式都不会暴露其层级以上的工具。

• 安全标志 — 主题 allowlist、保护内部/关键主题、删除开关、dry-run，以及 JSON 审计日志（见下文）。

• 认证 — 明文、TLS 和 SASL（PLAIN / SCRAM-SHA-256 / SCRAM-SHA-512）。

Related MCP server: Kafka MCP Server

安全模型

工具

读取（read-only+）：cluster_info、list_topics、describe_topic、topic_offsets、list_consumer_groups、describe_consumer_group（含 lag）

写入（read-write+）：create_topic、create_partitions、alter_topic_config、reset_consumer_group_offsets

管理（admin）：delete_topic、delete_consumer_group（二者均需 KAFKA_ALLOW_DELETE）

与你的 MCP 客户端配合使用

可配合 Claude Code、Claude Desktop、Cursor、OpenAI Codex CLI、Windsurf、VS Code（Copilot）以及任何其他 MCP 客户端使用——各客户端配置步骤请见 docs/CLIENTS.md。

安装

npm install
npm run build

使用 Claude Desktop / Claude Code 运行

{
  "mcpServers": {
    "kafka": {
      "command": "node",
      "args": ["/absolute/path/to/mcp-kafka/dist/index.js"],
      "env": {
        "KAFKA_BROKERS": "broker1:9092,broker2:9092",
        "KAFKA_MODE": "read-only",
        "KAFKA_SSL": "true",
        "KAFKA_SASL_MECHANISM": "scram-sha-512",
        "KAFKA_SASL_USERNAME": "mcp",
        "KAFKA_SASL_PASSWORD": "…"
      }
    }
  }
}

示例提示词

• "当前哪些消费者组的 lag 最严重？"

• "描述 orders 主题并展示其偏移量。"

• "创建一个 6 个分区、保留 7 天的 events 主题。"（需要 read-write）

开发

npm run dev
npm test
npm run typecheck

发布

本服务器提供了官方 MCP 注册表所需的 server.json，以及用于 npm 所有权验证的 mcpName。发布到 npm 并在 MCP 注册表、Smithery、Glama、Cursor 和 PulseMCP 上列出，请参阅 PUBLISHING.md。

许可证

MIT