MCP Kafka 处理器

一个 MCP 服务器实现，通过 Kafka 集成提供事件处理能力。此服务器允许大型语言模型通过模型上下文协议与 Kafka 主题交互。

特性

• 发布事件到 Kafka 主题
• 从 Kafka 主题消费事件
• 易于与 Claude Desktop 和其他 MCP 客户端集成
• 使用 TypeScript 的类型安全实现

先决条件

• Node.js 16 或更高版本
• 可访问的 Kafka broker
• TypeScript 开发知识

安装

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

# 安装依赖
npm install

# 构建项目
npm run build

配置

服务器可以使用环境变量进行配置：

• KAFKA_BROKERS: Kafka broker 的逗号分隔列表 (默认: "localhost:9092")

与 Claude Desktop 一起使用

将以下内容添加到您的 Claude Desktop 配置 (claude_desktop_config.json):

{
  "mcpServers": {
    "event-processor": {
      "command": "node",
      "args": ["/absolute/path/to/build/index.js"],
      "env": {
        "KAFKA_BROKERS": "localhost:9092"
      }
    }
  }
}

可用工具

publish-event

将消息发布到指定的 Kafka 主题。

参数：

• topic: 要发布到的 Kafka 主题
• message: 要发布的消息内容
• key: 可选的消息键

consume-events

从指定的 Kafka 主题消费消息。

参数：

• topic: 要消费的 Kafka 主题
• maxMessages: 要消费的最大消息数 (默认: 10)

开发

# 安装依赖
npm install

# 构建项目
npm run build

# 启动服务器
npm start

许可证

MIT