mcp-kafka

Apache Kafka 向けの Model Context Protocol サーバーです。MCP 対応クライアント（Claude Desktop、Claude Code など）が Kafka クラスターを監視・管理できるようにします。対象はトピック、パーティション、設定、コンシューマーグループ（ラグを含む）です。動作はすべてフラグによって制御されます。

デフォルトで安全です。読み取り専用で起動し、トピックの許可リスト（allowlist）にスコープを制限でき、内部/重要なトピックを変更から保護し、破壊的な操作は明示的なオプトインを必須とします。

機能

• モニタリング — クラスター/ブローカー情報、トピックメタデータとオフセット、コンシューマーグループ、および、パーティションごと＋合計のコンシューマーラグ。

• 管理 — トピックの作成、パーティションの追加、トピック設定の変更、グループオフセットのリセット、トピック/グループの削除（admin）。

• アクセスモード — read-only → read-write → admin。モードが自分のレベルより上のツールを公開しないように階層化されています。

• セキュリティフラグ — トピックの許可リスト、保護/内部トピック、削除のゲート制御、ドライラン、JSON 監査ログ（下記参照）。

• 認証 — 平文、TLS、SASL（PLAIN / SCRAM-SHA-256 / SCRAM-SHA-512）。

Related MCP server: Kafka MCP Server

セキュリティモデル

ツール

読み取り（read-only+）：cluster_info, list_topics, describe_topic, topic_offsets, list_consumer_groups, describe_consumer_group（ラグ表示あり）

書き込み（read-write+）：create_topic, create_partitions, alter_topic_config, reset_consumer_group_offsets

管理（admin）：delete_topic, delete_consumer_group（どちらも KAFKA_ALLOW_DELETE が必要）

MCP クライアントでの利用

Claude Code、Claude Desktop、Cursor、OpenAI Codex CLI、Windsurf、VS Code (Copilot)、および他の MCP クライアントで動作します。クライアントごとのセットアップは docs/CLIENTS.md を参照してください。

インストール

npm install
npm run build

Claude Desktop / Claude Code で実行する

{
  "mcpServers": {
    "kafka": {
      "command": "node",
      "args": ["/absolute/path/to/mcp-kafka/dist/index.js"],
      "env": {
        "KAFKA_BROKERS": "broker1:9092,broker2:9092",
        "KAFKA_MODE": "read-only",
        "KAFKA_SSL": "true",
        "KAFKA_SASL_MECHANISM": "scram-sha-512",
        "KAFKA_SASL_USERNAME": "mcp",
        "KAFKA_SASL_PASSWORD": "…"
      }
    }
  }
}

プロンプトの例

• "現在、どのコンシューマーグループが最もラグが大きいですか？"

• "orders トピックを説明し、そのオフセットを表示してください。"

• "events トピックを、パーティション 6 つ、保存期間 7 日で作成してください。"（read-write が必要）

開発

npm run dev
npm test
npm run typecheck

公開

このサーバーには、公式 MCP レジストリ用の server.json と、npm の所有権検証用の mcpName が同梱されています。npm への公開および MCP レジストリ、Smithery、Glama、Cursor、PulseMCP への掲載については、PUBLISHING.md を参照してください。

ライセンス

MIT