mcp-kafka

概要

mcp-kafka は、Apache Kafka 向けの、サーバーサイドでの model context protocol (MCP) の実装です。言語モデル（LLM/SLM）が、Kafka Connect、Burrow、Cruise Control などのエコシステムを含む Kafka と確実に連携できるようにします。

NOTE： 現在、開発中のため、変更やエラーの可能性があります。

機能

このサーバーは、（現時点では Streams を除く）Kafka のコア API と、Burrow および Cruise Control の REST API に基づく機能をサポートしています。

TODO

• asyncio と aiohttp を使用する。
• 環境設定値をデータクラスに設定する。
• admin/consumer/producer API のサポートを完了する。
• Burrow API をサポートする。
• CC API をサポートする。
• サービスおよび統合テスト。
• PyPI に公開する（uv pip install mcp-kafka）
• Dockerfile をテストし、Dockerhub にプッシュする（docker pull bkpowers/mcp-kafka）
• README に使用方法、設定、デプロイの選択肢、デモを追加する。
• Strimzi/kcctl との統合を検討する。
• 特定のリソースやツールに対する自動補完をサポートするプロンプト。

MCP の機能

ツール

Kafka

• consume
• produce
• describe_kafka_cluster
• describe_kafka_topics
• describe_kafka_consumer_groups
• describe_kafka_delegation_tokens
• describe_kafka_log_dirs
• describe_kafka_configs
• describe_kafka_acls

Kafka Connect

• get_kafka_connect_cluster_info
• get_kafka_connect_config
• get_kafka_connect_connectors
• get_kafka_connect_connector_plugins
• get_kafka_connect_loggers

Burrow

• burrow_healthcheck
• burrow_list_clusters
• burrow_describe_cluster
• burrow_list_consumers_with_group_detail
• burrow_list_topics
• burrow_check_consumer_group_status

Cruise Control

• cruise_control_get_state
• cruise_control_get_kafka_cluster_load
• cruise_control_get_partition_resource_utilization_and_load
• cruise_control_get_partition_and_replica_state
• cruise_control_get_optimization_proposals
• cruise_control_get_user_request_result

リソース

• トピック、コネクター、コンシューマーグループ

プロンプト

使用方法／設定

1. Claude Desktop
2. Cursor
3. Windsurf
4. Langchain MCP アダプター
5. Azure OpenAI

環境変数

現在、対応する API は、それぞれ固有の環境変数が設定されている場合に有効になります。環境変数が設定されていない場合、サーバーは空の状態で応答します。1 つ以上の環境変数が設定されている場合、対応するツールも利用可能になります。

• KAFKA_BOOTSTRAP_SERVERS：Kafka Admin、Consumer、Producer API
• KAFKA_CONNECT_API_URL：Kafka Connect API
• KAFKA_BURROW_API_URL：Burrow API
• KAFKA_CRUISE_CONTROL_API_URL：Cruise Control API