广告合作
MCP.so
登录

MCP Kafka工具

@yufule

代码仓库

基本信息

分类

其他

传输方式

stdio

作者

yufule

关于 MCP Kafka工具

MCP Kafka服务器 - 通过MCP协议连接Kafka，支持查询Topic信息、读写数据和回放历史数据

MCP Kafka工具 配置

使用下面的配置,将此服务器添加到你的 MCP 客户端。

{
  "mcpServers": {
    "mcp-kafka-server": {
      "command": "python",
      "args": [
        "mcp_kafka_server.py"
      ]
    }
  }
}

MCP Kafka工具 工具

工具列表暂未提供

当前收录暂时没有可展示的工具列表，不代表服务没有工具。请查阅项目文档了解支持的能力。

工具是从 README 中自动提取的。维护者可以在 ## Tools 标题下列出工具,即可填充这部分内容。

概览

What is MCP Kafka工具?

MCP Kafka工具是一个基于MCP（Model Context Protocol）协议的Kafka工具，可以通过大模型连接Kafka，实现查询主题信息、数据读写以及按时间回放等操作。

How to use MCP Kafka工具?

安装依赖后，以本地模式直接运行mcp_kafka_server.py，或以Web服务模式运行mcp_kafka_sse_server.py（启动在localhost:8000），然后在MCP客户端（如Claude、Cherry Studio）中连接对应节点即可使用。

Key features of MCP Kafka工具

  • 列出所有Kafka Topic
  • 获取指定Topic的详细信息
  • 向Topic发送消息
  • 读取Topic最新消息
  • 回放指定时间段的历史消息
  • 支持STDIO和SSE运行模式

Use cases of MCP Kafka工具

  • 通过大模型查询Kafka中所有主题
  • 通过大模型向指定主题发送消息
  • 通过大模型读取指定主题的最新消息
  • 通过大模型回放指定时间范围内的历史消息
  • 集成到Cherry Studio等MCP客户端中管理Kafka数据

常见问题

1

MCP Kafka工具需要哪些依赖？

需要Python环境，通过`pip install -r requirements.txt`安装依赖。

2

MCP Kafka工具默认连接的Kafka地址是什么？

默认连接到localhost:9092，可以在KafkaManager类的初始化参数中修改`bootstrap_servers`。

3

MCP Kafka工具支持哪些运行模式？

支持本地模式（STDIO）和Web服务模式（SSE），分别运行`mcp_kafka_server.py`和`mcp_kafka_sse_server.py`即可。

评论

其他 分类下的更多 MCP 服务器

MCP Toolbox for Databases

googleapis

MCP Toolbox for Databases is an open source MCP server for databases.

15.9K

Health by Dr Brad

Dr Brad Stanfield

Health by Dr Brad works out a health plan from your own results: which screening is due at your age, and evidence-based suggestions, each with the reason and the published guideline or study behind it. Your record is one

MaxKB

1Panel-dev

🔥 MaxKB is an open-source platform for building enterprise-grade agents. 强大易用的开源企业级智能体平台。

22.0K

EverArt

modelcontextprotocol

Model Context Protocol Servers

88.1K
N

Next Generation Movers: free moving quotes (remote MCP)

Next Generation Movers

Free moving quotes for AI agents from Next Generation Movers, a licensed interstate mover (USDOT 3764697). US long-distance nationwide and local DC/MD/VA. Indicative ballpark price and booking options; optional $0.01 x40

广告合作