Credits

🚀 Kafka MCP サーバー

Kafka MCP サーバーは、Model Context Protocol (MCP) のサーバー実装です。Apache Kafka との統合機能を提供し、自然言語（LLMs）を通じて Kafka クラスタとやり取りできるようになります。

デモ

🚀 クイックスタート

前提条件

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

手順

1. Kafka クラスタにアクセスする必要があります。クイックスタート ドキュメントに従って、以下のコマンドを実行します。

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

これで、Kafka は localhost:9092 を通じてアクセス可能になります。

Claude Desktop を使用する場合

Docker を使用する場合

以下の JSON 設定を使用します。

{
  "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] クラスタの説明（ブローカーとコントローラーのリスト）
• [x] コンシューマーグループの一覧表示と遅延の取得
• [x] トピックの最早および最新のオフセットの取得（GetOffsetShell）
• [ ] コンシューマーグループのオフセットのリセット
• [ ] Kafka Connect ??
• [ ] Schema Registry ??

🔀 MultiplexTool

MultiplexTool のデモ

複数の順次実行するツールを実行する場合、特に各ツールが前のツールの出力に依存する場合、クライアントとサーバー間の複数の往復が必要となり、非常に時間がかかり面倒です。MultiplexTool は、クライアントがツール呼び出しのリストを 1 つのリクエストにまとめ、順番に実行できるようにすることでこの問題を解決します。また、ヒントベースのプレースホルダーを使用して早期の出力を参照することで、ツール間の動的な依存関係をサポートしています。

ツールの入力が以前の結果に依存する場合、クライアントは 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