mcp-kafka

概述

mcp-kafka 是适用于 Apache Kafka 的服务端 模型上下文协议（MCP） 实现。它可让语言模型（LLM/SLM）可靠地与 Kafka 及其生态系统交互，包括 Kafka Connect、Burrow 和 Cruise Control。

注意： 该项目仍在开发中，预计会有更改和潜在错误。

功能

该服务支持基于 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

资源

• 主题、连接器、消费者组

提示词

用法 / 配置

1. Claude Desktop
2. Cursor
3. Windsurf
4. Langchain MCP adapter
5. Azure OpenAI

环境变量

目前，通过设置特定环境变量来启用相应的 API。如果没有设置任何环境变量，服务将返回空响应。如果设置了一个或多个变量，相应的工具也会启用。

• 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