Kafka MCP Server - MCP服务，MCP服务器，MCP教程

基本能力

产品定位

Kafka MCP Server 是一个中间件服务，旨在为AI模型和代理应用提供与Kafka消息系统的无缝集成。

核心功能

• 发布消息到Kafka主题
• 从Kafka主题消费消息

适用场景

• AI模型与消息系统的集成
• 代理应用的消息传递
• 需要异步处理消息的AI应用

工具列表

• kafka-publish: 发布信息到配置的Kafka主题
• kafka-consume: 从配置的Kafka主题消费信息（注意：一旦消息被读取，同一组ID无法再次读取）

常见问题解答

• 消息消费后无法再次读取：确保使用不同的组ID或从主题的开头读取。

使用教程

使用依赖

• Python 3.8+
• Apache Kafka实例

安装教程

1. 克隆仓库：
   bash
git clone <repository-url>
cd <repository-directory>
2. 创建并激活虚拟环境：
   bash
python -m venv venv
source venv/bin/activate # Windows: venv\Scripts\activate
3. 安装依赖：
   bash
pip install -r requirements.txt
   若无requirements.txt，安装以下包：
   bash
pip install aiokafka python-dotenv pydantic-settings mcp-server

调试方式

运行服务器：
bash
python main.py --transport stdio
可用传输选项：
- stdio: 标准输入/输出（默认）
- sse: 服务器发送事件