MCP Kafka工具

Name: MCP Kafka工具
Author: yufule

@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工具能实现哪些

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

Production-ready MCP integrations for AI applications

Klavis-AI

Klavis AI: MCP integration platforms that let AI agents use tools reliably at any scale

5.8K

Maestro

mobile-dev-inc

Painless E2E Automation for Mobile and Web

14.8K

Codelf

unbug

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

14.2K

Inbox Zero AI MCP

elie222

The world's best AI personal assistant for email. Open source app to help you reach inbox zero fast.

11.6K

🪟 Windows-MCP

CursorTouch

MCP Server for Computer Use in Windows

6.3K

MCP Kafka工具 について