MCP Kafka 工具
面向 Kafka 调试与监控场景的 MCP 服务,支持查询 Topic 元信息、生产与消费消息,以及按时间戳回放历史数据,常用于开发联调、问题排查和链路验证。
主要能力
- Topic 管理:查看 Topic 列表、分区、副本及配置信息。
- 消息收发:向指定 Topic 发送测试消息,或订阅消费消息内容。
- 时间回放:按时间戳或偏移量回放历史消息,便于复现异常时刻。
- 状态监控:查看消费组状态、积压情况(Lag)等关键指标。
鉴权说明
连接 Kafka 集群通常需要提供 Bootstrap 地址,以及相应的认证信息(如 SASL 用户名 / 密码、SSL 证书 或 API Key)。具体凭据由所接入的 Kafka 环境决定,需提前从运维或平台获取。