FindMCP Logo FindMCP.info
mcp-kafka

mcp-kafka

site icon
2025.03.18 41
GoKafka 管理消息队列数据库
mcp-kafka 是一个基于 Model Context Protocol (MCP) 的服务器，用于在 AI 助手和 Apache Kafka 之间建立桥梁，使 AI 助手能够直接与 Kafka 集群进行交互。该工具支持创建、管理和与 Kafka 主题和消息进行交互。
View on GitHub

Overview

基本能力

产品定位

mcp-kafka 是一个用于 AI 助手与 Apache Kafka 交互的中间件工具，旨在简化 Kafka 集群的管理和消息操作。

核心功能

  • 创建主题：创建新的 Kafka 主题，支持配置分区和复制因子。
  • 列出主题：获取集群中所有可用 Kafka 主题的列表。
  • 删除主题：移除现有的 Kafka 主题。
  • 描述主题：获取特定主题的详细信息，包括分区详情。
  • 生产消息：向 Kafka 主题发送消息，支持消息键和头信息。
  • 消费消息：从 Kafka 主题读取消息，支持配置超时时间。

适用场景

  • AI 助手需要与 Kafka 集群进行交互的场景。
  • 自动化 Kafka 主题管理和消息操作。
  • 开发人员需要快速测试和调试 Kafka 相关功能。

工具列表

  • mcp-kafka 可执行文件：提供 Kafka 操作的核心功能。
  • Claude Desktop 集成：支持与 Claude Desktop 集成，通过配置文件进行参数设置。

常见问题解答

  • 认证支持：目前支持 SASL_PLAINTEXT 和 PLAINTEXT 认证，不支持 SASL_SSL。
  • 配置参数：所有参数将从自然语言消息中自动派生。

使用教程

使用依赖

  • Go 1.24 或更高版本
  • 运行的 Kafka 集群（默认连接：localhost:9092）

安装教程

  1. 克隆仓库： bash git clone https://github.com/kanapuli/mcp-kafka.git cd mcp-kafka

  2. 构建应用程序： bash make build

  3. 可选：为特定平台构建： bash make build GOOS=darwin GOARCH=arm64

  4. 将可执行文件放置在系统 PATH 或专用工具目录中。

  5. 按照 Claude Desktop 工具安装指南 进行安装。

调试方式

  1. 使用以下 CLI 标志配置 Kafka 客户端： --bootstrap-servers=localhost:9092 --consumer-group-id=mcp-kafka-consumer-group --username='your_sasl_username' --password='your_sasl_password'

  2. 确保 Kafka 集群正常运行且可访问。

  3. 检查日志和错误信息以排查问题。

许可证

该项目遵循 MIT 开源许可条款，请参阅 MIT 了解完整条款。