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 个或多个环境变量存在，则相应的工具也会被启用。