MCP Kafka

概述

注： 这是一个WIP，预计会有变化/潜在错误。

特性

全部

• \[\]使用 asyncio 和 aiohttp.
• \[\]在数据类中设置env配置值。
• \[\]完成管理/消费者/生产者API支持。
• \[\]支持Burrow API。
• \[\]支持CC API。
• \[\]服务+集成测试。
• \[\]发布到PyPI(uv pip install mcp-kafka)
• \[\]测试Dockerfile并推送到Dockerhub(docker pull bkpowers/mcp-kafka)
• \[\]用法/配置/部署选项+README中的演示。
• \[\]考虑Strimzi/kctl集成。
• \[\]提示对某些资源/工具的自动完成支持。

MCP能力

工具

卡夫卡

• 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连接

• get_kafka_connect_cluster_info
• get_kafka_connect_config
• get_kafka_connect_connectors
• get_kafka_connect_connector_plugins
• get_kafka_connect_loggers

洞穴

• burrow_healthcheck
• burrow_list_clusters
• burrow_describe_cluster
• burrow_list_consumers_with_group_detail
• burrow_list_topics
• burrow_check_consumer_group_status

巡航控制

• 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. 克劳德桌面
2. 光标
3. 帆板运动
4. Langchain MCP适配器
5. Azure OpenAI

环境变量

支持的API（目前）是通过其特定环境变量的存在来启用的。如果不存在，服务器将响应为空。如果存在1个或多个变量，则相应的工具也存在。

• KAFKA_BOOTSTRAP_SERVERS：Kafka管理、消费者、生产者API
• KAFKA_CONNECT_API_URL：Kafka Connect API
• KAFKA_BURROW_API_URL：Burrow API
• KAFKA_CRUISE_CONTROL_API_URL：巡航控制API