MCP.so
登录

MCP Kafka工具

@yufule

代码仓库

关于 MCP Kafka工具

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

基本信息

分类

其他

运行时

python

传输方式

stdio

发布者

yufule

配置

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

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

工具

未检测到工具

工具是从 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数据

FAQ from MCP Kafka工具

MCP Kafka工具需要哪些依赖？

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

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

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

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

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

MCP Kafka工具能实现哪些

评论

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

XcodeBuildMCP

cameroncooke

A Model Context Protocol (MCP) server and CLI that provides tools for agent use when working on iOS and macOS projects.

6.0K

Maestro

mobile-dev-inc

Painless E2E Automation for Mobile and Web

14.8K

FastMCP v2 🚀

jlowin

🚀 The fast, Pythonic way to build MCP servers and clients.

26.0K

ICSS

chokcoco

不止于 CSS

20.7K

Codelf

unbug

A search tool helps dev to solve the naming things problem.

14.2K