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数据

よくある質問

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`即可。

「その他」の他のコンテンツ

DeepMark

DeepMark helps teachers deliver rapid, consistent marking with meaningful feedback for every student — in a fraction of the time. What once took a week, now takes one free period.

Glasswarp

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.