MCP Kafka 服务器

MCP Kafka 服务器

一个为 Apache Kafka 及其生态系统设计的 MCP 服务器。

GitHub
Created Bybrandon-powersbrandon-powers

快速入门

mcp-kafka 是基于模型上下文协议 (MCP) 的 Kafka 服务端实现。

主要功能

  • 支持 Kafka 核心 API（Admin/Consumer/Producer）
  • 集成 Burrow 和 Cruise Control REST API

使用步骤

  1. 设置环境变量启用所需 API：
    • KAFKA_BOOTSTRAP_SERVERS 启用 Kafka Admin/Consumer/Producer API。
    • KAFKA_CONNECT_API_URL 启用 Kafka Connect API。
    • KAFKA_BURROW_API_URL 启用 Burrow API。
    • KAFKA_CRUISE_CONTROL_API_URL 启用 Cruise Control API。
  2. 安装依赖并运行服务。
  3. 测试服务是否正常启动。

待办事项

  • 完善 API 支持。
  • 添加单元测试与集成测试。
  • 发布到 PyPI 和 Dockerhub。

更多详情请查看 README。