MCP Kafka工具需要哪些依赖?
需要Python环境,通过`pip install -r requirements.txt`安装依赖。
@yufule
Basic information
MCP Kafka服务器 - 通过MCP协议连接Kafka,支持查询Topic信息、读写数据和回放历史数据
Add this server to your MCP-compatible client using the configuration below.
{
"mcpServers": {
"mcp-kafka-server": {
"command": "python",
"args": [
"mcp_kafka_server.py"
]
}
}
}Tool list not available yet
This listing does not currently have a tool list to display. This does not mean the server has no tools; check its documentation for supported capabilities.
We auto-extract tools from the README. The maintainer can list them under a ## Tools heading to populate this section.
MCP Kafka工具是一个基于MCP(Model Context Protocol)协议的Kafka工具,可以通过大模型连接Kafka,实现查询主题信息、数据读写以及按时间回放等操作。
安装依赖后,以本地模式直接运行mcp_kafka_server.py,或以Web服务模式运行mcp_kafka_sse_server.py(启动在localhost:8000),然后在MCP客户端(如Claude、Cherry Studio)中连接对应节点即可使用。
需要Python环境,通过`pip install -r requirements.txt`安装依赖。
默认连接到localhost:9092,可以在KafkaManager类的初始化参数中修改`bootstrap_servers`。
支持本地模式(STDIO)和Web服务模式(SSE),分别运行`mcp_kafka_server.py`和`mcp_kafka_sse_server.py`即可。
YC (S26) | Open Computer History | Continuously record your company computer work, map your workflows, help you find work worth automating, and power your agents' context

See and control a real Windows PC you own — from any MCP client, locally or remotely. Observe (UIA + screenshots), click/type/drag/scroll, launch apps, owner Live View. BYOH: your machine, your key.
Painless E2E Automation for Mobile and Web

Connect your AI assistant to your own YOUB endurance training account. Read recorded activities with full analysis, planned sessions, race goals, wellness (HRV, sleep, resting HR) and your athletic profile. Create or mov

Soar Flight Booking MCP is a remote MCP server available at https://mcp.soar.flights.
Comments