用途:该技能用于把 Kafka 操作接入 Claude Desktop 与 SpecWeave,指导配置 Kafka MCP(Model Context Protocol)服务器,支持四种实现的自动检测与配置生成。
主要能力:支持 kanapuli/mcp-kafka(Node.js,SASL_PLAINTEXT、PLAINTEXT,produce、consume、list-topics、describe-topic、get-offsets)、tuannvm/kafka-mcp-server(Go,支持 SCRAM-SHA-256/512、SASL_SSL,含消费者组与偏移管理,适合生产)、Joel-hanson/kafka-mcp-server(Python,适合 Claude Desktop)、Confluent 官方 MCP(企业版,支持 OAuth、Schema Registry、ksqlDB、Flink SQL)。提供能力对比与自动检测排序(Confluent > tuannvm > kanapuli > Joel-hanson)。
使用方式:安装命令如 npm install -g mcp-kafka、go install github.com/tuannvm/kafka-mcp-server@latest、pip install kafka-mcp-server、confluent plugin install mcp-server;配置 .mcp.json 或通过 /sw-kafka:mcp-configure 交互式向导完成检测、broker 配置、认证与连接测试。也可手动创建 .mcp.json 指定 serverType、brokerUrls 与 authentication。
适用场景:交互式调试、主题探索、Claude Desktop 集成;CI/CD、测试自动化与生产脚本建议直接使用 kafkajs 或 kafka-node 代码(约节省 98% token)。
限制:不同 MCP 服务器能力差异大,部分不支持消费者组、偏移管理、Schema Registry、ksqlDB 或 OAuth;凭据不应提交到仓库,建议使用环境变量或密钥管理,优先 SCRAM-SHA-512 与 TLS/SSL,并遵循最小权限原则。具体价格、平台与效果暂未提供。