MCP Kafka

🚀 mcp-kafka

mcp-kafka は、モデルコンテキストプロトコル (MCP) を Apache Kafka サーバー側で実装したものです。これにより、言語モデル（LLM/SLM）がKafkaとそのエコシステム（Kafka Connect、Burrow、Cruise Control を含む）と確実にやり取りできるようになります。

⚠️ 重要提示

これはWIP（進行中）のプロジェクトであり、変更や潜在的なエラーが予想されます。

✨ 主な機能

このサーバーは、コアKafka API（現在はStreamsを除く）、および Burrow と Cruise Control のREST APIをサポートしています。

今後の予定

• [ ] 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

リソース

• topic, connector, consumer group

プロンプト

📚 ドキュメント

使用/構成

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

環境変数

サポートされるAPIは、特定の環境変数の存在によって有効化されます。環境変数が存在しない場合、サーバーは空のレスポンスを返します。1つ以上の環境変数が存在する場合、対応するツールも有効になります。