快速入门

前置条件

• 安装 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 配置：

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。

工具

• kafka-publish：向配置的主题发布消息。
• kafka-consume：从配置的主题消费消息。