技术文档摘要

概述

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 (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 适配器
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