Mcp Kafka Processor

基本能力

产品定位

MCP Kafka Processor 是一个中间件服务，专注于在 Kafka 和 MCP 协议之间建立桥梁，为 LLM 提供高效的事件处理能力。

核心功能

• 发布事件到 Kafka 主题：支持将消息发布到指定的 Kafka 主题。
• 从 Kafka 主题消费事件：支持从指定的 Kafka 主题消费消息。
• 与 Claude Desktop 等 MCP 客户端集成：提供无缝的集成体验。
• 类型安全实现：使用 TypeScript 实现，确保类型安全。

适用场景

• 实时事件处理：适用于需要实时处理 Kafka 事件的场景。
• LLM 与 Kafka 集成：适用于需要将 LLM 与 Kafka 集成的应用。
• 数据流处理：适用于需要处理数据流的应用。

工具列表

• publish-event：将消息发布到指定的 Kafka 主题。
• 参数：
  • topic：Kafka 主题名称。
  • message：要发布的消息内容。
  • key（可选）：消息键。
• consume-events：从指定的 Kafka 主题消费消息。
• 参数：
  • topic：Kafka 主题名称。
  • maxMessages（可选，默认 10）：最大消费消息数。

常见问题解答

• 依赖问题：确保 Node.js 16 或更高版本已安装，Kafka 代理可访问，并具备 TypeScript 知识。
• 配置问题：通过环境变量 KAFKA_BROKERS 配置 Kafka 代理地址（默认：localhost:9092）。

使用教程

使用依赖

• Node.js 16 或更高版本：确保已安装。
• Kafka 代理：确保可访问。
• TypeScript 知识：建议具备。

安装教程

# 克隆仓库
git clone https://github.com/boufnichel/mcp-kafka-processor.git
cd mcp-kafka-processor

# 安装依赖
npm install

# 构建项目
npm run build

调试方式

# 安装依赖
npm install

# 构建项目
npm run build

# 启动服务
npm start

许可证

该项目遵循 MIT 开源许可条款。