金大哥 - mcp-kafka MCP 详情

article

README

🚀 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

提示词

📚 详细文档

使用/配置

可在以下环境中使用本项目：

Claude Desktop
Cursor
Windsurf
Langchain MCP 适配器
Azure OpenAI

环境变量

通过特定环境变量的存在来启用支持的 API。如果没有环境变量存在，服务器将返回空响应。如果有 1 个或多个环境变量存在，则相应的工具也会被启用。 | 属性 | 详情 | |------|------| | KAFKA_BOOTSTRAP_SERVERS | Kafka Admin, Consumer, Producer APIs | | KAFKA_CONNECT_API_URL | Kafka Connect API | | KAFKA_BURROW_API_URL | Burrow API | | KAFKA_CRUISE_CONTROL_API_URL | Cruise Control API |

mcp-kafka