Apache Kafka MCP Server
Kafka MCPサーバーでClaudeがメッセージキューを管理
npx kafka-mcp-server概要
Apache Kafka MCP Serverの設定方法と使い方。
分散メッセージキューシステム「Apache Kafka」をClaudeから操作できるMCPサーバー。
トピックの一覧取得・作成、メッセージのプロデュース（送信）・コンシューム（受信）、コンシューマーグループの管理が可能。
ClaudeとKafkaのMCPサーバー連携でメッセージフロー分析・トピック管理・デバッグ作業を自動化できる。
テスト用メッセージの自動生成・送信や、コンシューマーグループのラグ監視にClaudeを活用する使い方も可能。
設定方法はブローカーアドレスを環境変数に指定するだけで、データエンジニアがKafkaクラスターの運用管理を自然語で操作できる唯一のMCPサーバー。
料金・APIキー情報
料金
無料プランありAPIキー
🔑 必要🔑 APIキーの取得方法
- 1
ローカルKafkaの場合: Kafkaインストール後、ブローカーURLは「localhost:9092」で認証不要
- 2
Confluent Cloud（マネージドKafka）の場合: https://confluent.cloud でサインアップ（無料クレジットあり）
- 3
クラスター作成後「API Keys」→「Create key」でAPIキーとシークレットを生成
- 4
接続情報（Bootstrap server URL）を「Cluster settings」から取得
- 5
コピーしたAPIキーとシークレットキーを保存する（再表示不可のため必ず保存すること）
こんな使い方ができます
Kafkaのトピック一覧とメッセージをClaudeに分析させてデータフローを把握できる
テスト用のメッセージをClaudeに生成させてKafkaトピックに送信できる
コンシューマーグループのラグをClaudeに監視させて遅延アラートを管理できる
セットアップ手順
- 1
Apache Kafkaクラスターを用意する（ローカルまたはConfluentなどのクラウドサービス）
- 2
Kafkaブローカーのアドレスとポートをメモしておく
- 3
認証が必要な場合はユーザー名・パスワードまたはSASL認証情報を取得する
- 4
ターミナルで以下のコマンドを実行してClaude Codeに追加する：claude mcp add kafka -e KAFKA_BROKERS=localhost:9092 -e KAFKA_CLIENT_ID=mcp-client -- npx -y kafka-mcp-server
設定ファイル
コピー前に確認
Apache Kafkaクラスターへのアクセスが必要。ブローカーアドレスを指定する
claude mcp add kafka -e KAFKA_BROKERS=localhost:9092 -e KAFKA_CLIENT_ID=mcp-client -- npx -y kafka-mcp-server