Kafka MCP Server
2025.03.20
10
Python消息服务AI集成开发效率交流协作
Kafka MCP Server 是一个基于 Apache Kafka 的消息上下文协议（MCP）服务器，专为大型语言模型（LLM）和代理应用设计，提供发布和消费消息的功能。它通过标准化接口使AI模型能够与Kafka主题交互，支持消息的发布和消费。
View on GitHub
Overview
基本能力
产品定位
Kafka MCP Server 是一个中间件服务，旨在为AI模型和代理应用提供与Kafka消息系统的无缝集成。
核心功能
- 发布消息到Kafka主题
- 从Kafka主题消费消息
适用场景
- AI模型与消息系统的集成
- 代理应用的消息传递
- 需要异步处理消息的AI应用
工具列表
- kafka-publish: 发布信息到配置的Kafka主题
- kafka-consume: 从配置的Kafka主题消费信息（注意：一旦消息被读取，同一组ID无法再次读取）
常见问题解答
- 消息消费后无法再次读取：确保使用不同的组ID或从主题的开头读取。
使用教程
使用依赖
- Python 3.8+
- Apache Kafka实例
安装教程
- 克隆仓库：
bash git clone <repository-url> cd <repository-directory> - 创建并激活虚拟环境：
bash python -m venv venv source venv/bin/activate # Windows: venv\Scripts\activate - 安装依赖：
bash pip install -r requirements.txt若无requirements.txt，安装以下包：bash pip install aiokafka python-dotenv pydantic-settings mcp-server
调试方式
运行服务器：
python main.py --transport stdio
可用传输选项：
- stdio: 标准输入/输出（默认）
- sse: 服务器发送事件