用途
mcp-kafka 是一个用于 Apache Kafka 的 Model Context Protocol（MCP）服务器。它让具备 MCP 能力的客户端（例如 Claude Desktop、Claude Code 等）能够监控和管理 Kafka 集群，涵盖主题（topics）、分区（partitions）、配置（configs）以及消费者组（consumer groups，包括消费延迟 lag）。服务器的行为完全由标志（flags）控制。
主要能力
监控
- 集群/代理（broker）信息
- 主题元数据和偏移量
- 消费者组
- 每个分区以及总体的消费者延迟（consumer lag）
管理
- 创建主题
- 增加分区
- 修改主题配置
- 重置消费者组偏移量
- 删除主题/消费者组（管理员模式）
访问模式
采用分层设计：只读（read-only）→ 读写（read-write）→ 管理员（admin）。一个模式永远不会暴露高于其级别的工具。
安全标志
- 主题允许列表（topic allowlist）
- 受保护/内部主题（protected/internal topics）
- 删除门控（delete gating）
- 试运行（dry-run）
- JSON 审计日志（JSON audit logging）
认证
支持明文（plaintext）、TLS 和 SASL（PLAIN / SCRAM-SHA-256 / SCRAM-SHA-512）。
工具列表
只读（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 标志。
使用方式
快速开始——添加到你的智能体
已发布到 npm 为 @dockndevai/mcp-kafka。无需克隆或构建——你的 MCP 客户端会通过 npx 按需运行它。建议从只读模式开始；所有变量请参见 .env.example，完整的各客户端指南请参见 docs/CLIENTS.md。
- Claude Code（CLI）：资料提及该客户端支持，但未提供具体配置代码。
- Claude Desktop、Cursor、Windsurf：使用相同的配置块，放入 claude_desktop_config.json、.cursor/mcp.json 或 ~/.codeium/windsurf/mcp_config.json 中。
- OpenAI Codex CLI：在 ~/.codex/config.toml 中配置。
- VS Code（GitHub Copilot，Agent 模式）：在 .vscode/mcp.json 中配置。
（资料中上述客户端的具体配置代码块未在提供的文本中给出。）
示例提示词
- "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."（需要 read-write）
从源码运行（开发）
优先使用上面已发布的包。如需从克隆运行，资料提到可以，但未提供具体命令。
该服务器附带一个用于官方 MCP 注册表的 server.json，以及用于 npm 所有权验证的 mcpName。有关发布到 npm 以及在 MCP registry、Smithery、Glama、Cursor 和 PulseMCP 上列出的信息，请参见 PUBLISHING.md。
适用场景
适用于需要通过 MCP 客户端监控和管理 Kafka 集群的运维人员、开发者或智能体工作流。
限制
- 默认以只读模式启动，删除等破坏性操作需要显式开启删除门控并处于管理员模式。
- 访问模式分层，低级别模式无法使用高级别工具。
- 需配置主题允许列表和受保护/内部主题以增强安全性。
- 具体客户端配置代码、环境变量细节和源码运行命令在提供的资料中未完整给出，暂未提供。
