kafka-mcp-server

Kafka MCP Server

Kafka MCP Server は、自然言語（LLM）を使って Kafka クラスターとやり取りできるよう、Apache Kafka との統合を提供する Model Context Protocol (MCP) サーバーです。

デモ

前提条件

MCP サーバーをローカルで実行するには、Docker または Golang が必要です。

はじめに

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 <workdir>
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": "<workdir>/kafka-mcp-server/kafka-mcp-server",
      "args": [
        "stdio",
      ],
      "env": {
        "KAFKA_MCP_BOOTSTRAP_SERVERS": "localhost:9092"
      }
    }
  }
}

オプション：

      --bootstrap-servers string   Comma-separated list of the Kafka servers to connect to.
      --enable-command-logging     When enabled, the server will log all command requests and responses to the log file
      --log-file string            Path to log file
      --read-only                  Restrict the server to read-only operations

すべてのオプションは環境変数として渡すことができます。大文字にし、ハイフンをアンダースコアに置き換え、MCP_KAFKA_ を前置します。たとえば、--bootstrap-servers は MCP_KAFKA_BOOTSTRAP_SERVERS になります。

利用可能な MCP ツール

• トピックの一覧表示
• トピックの作成
• メッセージの消費。
• メッセージの生成。
• クラスターの説明（ブローカーとコントローラーの一覧）
• コンシューマーグループとそのラグの一覧表示。
• トピックの最古および最新のオフセットの取得（GetOffsetShell）
• コンシューマーグループのオフセットのリセット。
• Kafka Connect ??
• Schema Registry ??

🔀 MultiplexTool

MultiplexTool のデモ

多くのツールを順番に実行するのは、特に各ツールが直前の出力に依存する場合、面倒で時間がかかります。そのため、クライアントとサーバーの間で何度もやり取りする必要があります。

MultiplexTool を使うと、クライアントはツール呼び出しのリストを1つのリクエストにまとめ、順番に実行できます。また、プロンプトベースのプレースホルダーを使って以前の出力を参照し、ツール間の動的な依存関係をサポートします。

ツールの入力が前の結果に依存する場合、クライアントは PROMPT_ARGUMENT: 形式を使用して、LLM へのプロンプトを通じてその入力を動的に生成します（現在は Gemini のみサポートされています）。
例：
"userId": "PROMPT_ARGUMENT: the ID of the created user"

CLI フラグ：

• --enable-multiplex：ツール呼び出しの多重化を有効にします。
• --multiplex-model：PROMPT_ARGUMENT の推論に使用するモデル（例：gemini）を指定します。GEMINI_API_KEY 環境変数が必要です。

{
  "mcpServers": {
    "kafka": {
      "command": "docker",
      "args": [
        "run",
        "-i",
        "--rm",
        "-e",
        "KAFKA_MCP_BOOTSTRAP_SERVERS",
        "ghcr.io/cefboud/kafka-mcp-server",
        "--enable-multiplex",
        "--multiplex-model",
        "gemini"
      ],
      "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