Confluent MCP：让智能体看 Kafka 主题、查消费延迟
Confluent 开源的 Kafka MCP。智能体能管理主题、收发消息、查消费组延迟，也能用 Flink SQL；本地 Kafka 无需云账号。
项目与安装文档
查看项目https://github.com/confluentinc/mcp-confluent
消费者卡住、某个主题积压了几十万条消息，排查时要在命令行、控制台和监控之间来回切。Confluent MCP 把 Kafka 的日常操作做成 MCP 工具，智能体能直接列主题、看消费组延迟、取几条消息看看格式。它由 Confluent 开源，截至 2026-10-06 约 170 star，在 Kafka 圈外知道的人不多。
能做什么
- Kafka 主题与消息：
list-topics、create-topics、delete-topics管理主题，produce-message、consume-messages收发消息。 - 消费组排查：
list-consumer-groups、describe-consumer-group、get-consumer-group-lag看消费组状态和延迟。 - Schema Registry：
list-schemas、create-schema、delete-schema管理数据结构定义。 - Confluent Cloud 扩展：配置云端凭据后，再开放 Flink SQL 语句、Flink 目录、连接器和 Tableflow 等工具，README 统计共 50 多个。
- 自诊断：不用任何凭据就能用的
explain-disabled-tools、list-configured-connections、config-help几个工具，帮你看清哪些工具因为配置缺失没启用、该补哪段 YAML。
适合谁
- 维护 Kafka 集群、想让智能体帮忙定位积压和消费延迟的后端或平台工程师。
- 在 Confluent Cloud 上写 Flink SQL、希望用自然语言提交和查看语句的数据工程师。
接入方式
需要 Node.js 22.19 或更新版本。先生成配置文件，填好 Kafka 地址（本地集群只需 bootstrap_servers），再启动：
npx @confluentinc/mcp-confluent --init-config
npx @confluentinc/mcp-confluent --config ./config.yaml
各客户端的接入步骤见仓库 docs/ 目录。连 Confluent Cloud 时也可以不填静态密钥，第一次调用需要云端权限的工具时，服务会打开浏览器走 OAuth 登录，之后的调用复用同一个会话。
编辑点评
流数据平台的 MCP 很少，这个出自 Kafka 生态的头部厂商，而且不绑定自家云：普通的自建 Kafka、Schema Registry，乃至自管的 Confluent Platform 集群都能连，拿到的工具和本地部署一样；Confluent 自己也提供一个无需本地运行的托管 MCP 服务，更看重免运维可以直接用那个。它的工具按配置自动启用，--allow-tools、--block-tools 可以精确控制，建议一开始就屏蔽 delete-topics、produce-message 这类会改动线上数据的工具。两点要知道：README 写明开源版只提供社区级支持，Confluent Cloud 用户另有托管版；服务默认上报使用数据和错误到 Sentry，设 DO_NOT_TRACK=true 关闭。数据这一格里它和 DuckDB / MotherDuck MCP 不冲突：一个管消息流，一个管分析查询。许可证为 MIT。