AI导哈

Kafka模型上下文协议服务

mcp-kafka是一个基于模型上下文协议（MCP）的服务器端实现，用于Apache Kafka及其生态系统，使语言模型能够可靠地与Kafka交互。

  • by brandon-powers
  • Python
  • 本地部署
  • 3 星标
  • 更新于
在 GitHub 查看 brandon-powers/mcp-kafka

使用说明

概述

mcp-kafka 是服务器端的实现 模型上下文协议 为了 **Apache Kafka**它允许语言模型（LLM/SLM）与Kafka及其生态系统可靠地交互，包括 Kafka连接, 洞穴, & 巡航控制.

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

特性

服务器支持基于 核心Kafka API，不包括Streams（目前），以及 洞穴 & 巡航控制 REST API。

全部

  • []使用 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

相关 MCP