Kafka MCP 服务器

Kafka MCP 服务器

一个与 Apache Kafka 集成的消息上下文协议 (MCP) 服务器，支持发布和消费消息。

GitHub
Created Bypavanjavapavanjava

快速入门

概述

本项目实现了一个与 Kafka 主题交互的服务器，支持发布和消费消息。

前置要求

  • Python 3.8+
  • Apache Kafka 实例

安装步骤

  1. 克隆仓库： git clone cd

  2. 创建并激活虚拟环境： python -m venv venv source venv/bin/activate （Windows 使用：venv\Scripts\activate）

  3. 安装依赖： pip install -r requirements.txt

    如果没有 requirements.txt 文件，安装以下包： pip install aiokafka python-dotenv pydantic-settings mcp-server

配置

在项目根目录创建 .env 文件，内容如下：

KAFKA_BOOTSTRAP_SERVERS=localhost:9092
TOPIC_NAME=your-topic-name
IS_TOPIC_READ_FROM_BEGINNING=False
DEFAULT_GROUP_ID_FOR_CONSUMER=kafka-mcp-group

启动服务器

运行以下命令： python main.py --transport stdio

支持的传输选项：stdio（默认）或 sse。