mcp-kafka

mcp-kafka

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

デフォルトで安全です。読み取り専用で起動し、許可リストにあるトピックだけに対象を絞り、内部／重要なトピックの変更を防ぎ、破壊的な操作には明示的なオプトインを求めます。

機能

• 監視 — クラスター／ブローカーの情報、トピックのメタデータとオフセット、コンシューマーグループ、およびパーティションごとと合計のコンシューマーラグ。
• 管理 — トピックの作成、パーティションの追加、トピック設定の変更、グループオフセットのリセット、トピック／グループの削除（管理者）。
• アクセスモード — read-only → read-write → admin の順に権限が増え、各モードではそのレベルを超えるツールは公開されません。
• セキュリティフラグ — トピックの許可リスト、保護対象／内部トピック、削除のゲート、ドライラン、JSON 監査ログ（以下を参照）。
• 認証 — プレーンテキスト、TLS、SASL（PLAIN／SCRAM-SHA-256／SCRAM-SHA-512）。

セキュリティモデル

懸念事項	フラグ	デフォルト	効果
サーバーでできること	KAFKA_MODE	read-only	read-only では監視のみが可能です。read-write では管理機能が追加され、admin では削除機能が追加されます。モードの権限を超えるツールは登録されません。
対象となるトピック	KAFKA_TOPIC_ALLOWLIST	(すべて)	設定すると、ほかのトピックに対する操作は拒否されます。
内部トピックの保護	KAFKA_PROTECT_INTERNAL_TOPICS	true	_ で始まるトピックは読み取りできますが、変更はできません。
特定のトピックの保護	KAFKA_PROTECTED_TOPICS	(なし)	追加の、常時読み取り専用となるトピックです。
削除の可否	KAFKA_ALLOW_DELETE	false	delete_topic／delete_consumer_group には、この設定と admin モードの両方が必要です。
クラスターに触れずにプレビュー	KAFKA_DRY_RUN	false	書き込み／管理ツールは検証して意図をログに記録した後、処理を返します。
監査証跡	KAFKA_AUDIT_LOG	true	保護された操作ごとに、JSON 形式の行を stderr に出力します。
対話型の確認	(自動)	—	破壊的な操作や影響の大きい操作を実行する前に、MCP エリシテーションを通じて人間に承認を求めます。エリシテーションに対応しないクライアントでは、代わりに *_ALLOW_* ゲートが適用されます。

ツール

読み取り（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 が必要）

クイックスタート — エージェントに追加する

npm で @dockndevai/mcp-kafka として公開されています。クローンやビルドは不要です。MCP クライアントが npx で必要に応じて実行します。まずは read-only モードで開始してください。すべての変数については .env.example を、クライアントごとの詳しいガイドについては docs/CLIENTS.md を参照してください。

Claude Code（CLI）

claude mcp add kafka -e KAFKA_BROKERS="localhost:9092" -e KAFKA_MODE="read-only" -- npx -y @dockndevai/mcp-kafka

Claude Desktop · Cursor · Windsurf — claude_desktop_config.json、.cursor/mcp.json、または ~/.codeium/windsurf/mcp_config.json に同じブロックを追加します。

{
  "mcpServers": {
    "kafka": {
      "command": "npx",
      "args": [
        "-y",
        "@dockndevai/mcp-kafka"
      ],
      "env": {
        "KAFKA_BROKERS": "localhost:9092",
        "KAFKA_MODE": "read-only"
      }
    }
  }
}

OpenAI Codex CLI — ~/.codex/config.toml に追加します。

[mcp_servers.kafka]
command = "npx"
args = ["-y", "@dockndevai/mcp-kafka"]
env = { KAFKA_BROKERS = "localhost:9092", KAFKA_MODE = "read-only" }

VS Code（GitHub Copilot、エージェントモード） — .vscode/mcp.json に追加します。

{
  "servers": {
    "kafka": {
      "type": "stdio",
      "command": "npx",
      "args": [
        "-y",
        "@dockndevai/mcp-kafka"
      ],
      "env": {
        "KAFKA_BROKERS": "localhost:9092",
        "KAFKA_MODE": "read-only"
      }
    }
  }
}

プロンプトの例

• 「現在、ラグが最も大きいコンシューマーグループはどれですか？」
• 「orders トピックの詳細を説明して、オフセットを表示してください。」
• 「パーティション数 6、保持期間 7 日で events トピックを作成してください。」（read-write が必要）

ソースから実行する（開発）

上記の公開パッケージを推奨します。クローンから実行するには：

npm install
npm run build
node dist/index.js   # with the environment variables set

開発

npm run dev
npm test
npm run typecheck

公開

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

ライセンス

MIT