Credits

🚀 Kafka MCP 服務器

Kafka MCP 服務器是 Model Context Protocol (MCP) 的服務器實現，它集成了 Apache Kafka 功能，可藉助自然語言（LLMs）與 Kafka 集群進行交互。

演示示例

🚀 快速開始

先決條件

要在本地運行 MCP 服務器，您需要安裝 Docker 或 Golang。

啟動 Kafka 集群

您需要訪問一個 Kafka 集群。可按照 快速入門 文檔進行操作：

docker pull apache/kafka:4.0.0
docker run -p 9092:9092 apache/kafka:4.0.0

現在，Kafka 可以通過 localhost:9092 進行訪問。

使用 Claude Desktop

Docker 方式

{
  "mcpServers": {
    "kafka": {
      "command": "docker",
      "args": [
        "run",
        "-i",
        "--rm",
        "-e",
        "KAFKA_MCP_BOOTSTRAP_SERVERS",
        "ghcr.io/cefboud/kafka-mcp-server"
      ],
      "env": {
        "KAFKA_MCP_BOOTSTRAP_SERVERS": "localhost:9092"
      }
    }
  }
}

本地構建方式

cd <工作目錄>
git clone https://github.com/CefBoud/kafka-mcp-server.git
cd kafka-mcp-server
go build -o kafka-mcp-server cmd/kafka-mcp-server/main.go

{
  "mcpServers": {
    "kafka": {
      "command": "<工作目錄>/kafka-mcp-server/kafka-mcp-server",
      "args": [
        "stdio",
      ],
      "env": {
        "KAFKA_MCP_BOOTSTRAP_SERVERS": "localhost:9092"
      }
    }
  }
}

選項說明

      --bootstrap-servers string   分隔的 Kafka 服務器列表，用於連接。
      --enable-command-logging     開啟此選項後，服務器將記錄所有命令請求和響應到日誌文件中
      --log-file string            日誌文件路徑
      --read-only                  限制服務器僅執行只讀操作

所有選項都可以作為環境變量傳遞，需將選項名大寫，使用下劃線替換連字符，並以 MCP_KAFKA_ 為前綴。例如，--bootstrap-servers 轉換為 MCP_KAFKA_BOOTSTRAP_SERVERS。

✨ 主要特性

可用的 MCP 工具

• [x] 列出主題
• [x] 創建主題
• [x] 消費消息
• [x] 生產消息
• [x] 描述集群（ broker 和 controller 的列表）
• [x] 列出消費者組及其滯後
• [x] 獲取主題的最早和最新偏移量（GetOffsetShell）
• [ ] 重置消費者組偏移量
• [ ] Kafka Connect ??
• [ ] Schema Registry ??

🔀 MultiplexTool

MultiplexTool 演示

運行多個順序工具，特別是當每個工具依賴於前一個的輸出時，可能會非常耗時和繁瑣，這需要在客戶端和服務器之間進行多次往返。MultiplexTool 可解決此問題，它允許客戶端將一列表工具調用批量為一個請求，並按順序執行。它支持工具之間的動態依賴關係，通過使用基於提示的佔位符讓您可以引用早期輸出。

如果工具輸入取決於先前的結果，客戶端可以使用 PROMPT_ARGUMENT: 格式通過提示生成該輸入（當前僅支持 Gemini）。 示例：
"userId": "PROMPT_ARGUMENT: 創建的用戶的 ID"

CLI 選項：

• --enable-multiplex：啟用多路複用功能
• --multiplex-config string：指定多路複用配置文件路徑

配置示例

{
  "mcpServers": {
    "kafka": {
      "command": "docker",
      "args": [
        "run",
        "-i",
        "--rm",
        "-e",
        "KAFKA_MCP_BOOTSTRAP_SERVERS",
        "ghcr.io/cefboud/kafka-multiplex-server:latest"
      ],
      "env": {
        "KAFKA_MCP_BOOTSTRAP_SERVERS": "localhost:9092",
        "GEMINI_API_KEY": "....."
      }
    }
  }
}

📄 許可證

知識產權

• github.com/github/github-mcp-server
• github.com/mark3labs/mcp-go
• github.com/IBM/sarama