MCP Kafka工具
@yufule
About MCP Kafka工具
MCP Kafka服务器 - 通过MCP协议连接Kafka，支持查询Topic信息、读写数据和回放历史数据
Basic information
Config
Add this server to your MCP-compatible client using the configuration below.
{
"mcpServers": {
"mcp-kafka-server": {
"command": "python",
"args": [
"mcp_kafka_server.py"
]
}
}
}Tools
No tools detected
We auto-extract tools from the README. The maintainer can list them under a ## Tools heading to populate this section.
Overview
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工具能实现哪些
More Other MCP servers
Production-ready MCP integrations for AI applications
Klavis-AIKlavis AI: MCP integration platforms that let AI agents use tools reliably at any scale
Mcp
browsermcpBrowser MCP is a Model Context Provider (MCP) server that allows AI applications to control your browser
MCP Toolbox for Databases
googleapisMCP Toolbox for Databases is an open source MCP server for databases.
🪟 Windows-MCP
CursorTouchMCP Server for Computer Use in Windows
Blender
ahujasidOpen-source MCP to use Blender with any LLM
Comments