MCP Kafka

🚀 mcp-kafka

mcp-kafka 是 模型上下文協議 (MCP) 在 Apache Kafka 服務端的實現方案。它能讓語言模型（LLM/SLM）與 Kafka 及其生態系統（涵蓋 Kafka Connect、Burrow 和 Cruise Control）進行可靠交互。

⚠️ 重要提示

此項目正在開發中（WIP），後續可能會有更改或存在潛在錯誤。

🚀 快速開始

本項目允許語言模型與 Kafka 及其生態系統交互，使用前需瞭解相關配置和環境變量設置。

✨ 主要特性

服務器支持功能

該服務器支持基於 核心 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 個或多個環境變量存在，則相應的工具也會被啟用。