Kafka MCP
概述
Kafka MCP Server提供了将提示转换为动作到Kafka生态系统中的有效方法。这是一种自然 为代理应用程序设计的语言界面，可有效管理Kafka操作并无缝集成 MCP客户端使AI驱动的工作流能够与Kafka中的进程进行交互。使用此MCP服务器，您可以询问 问题如下：
- 在“测试kafka”主题下发布消息“我正在使用kafka服务器”
- 使用主题“测试卡夫卡”中的信息
- 列出卡夫卡环境中的所有主题
特性
- 自然语言查询：使AI代理能够使用自然语言查询和更新Redis。
- 无缝MCP集成：可与任何MCP客户端配合使用，实现顺畅的通信。
- 完全支持Kafka：处理生产者、消费者、主题、代理、分区和偏移。
- 可扩展和轻量级：专为高性能数据操作而设计。
工具
此MCP服务器为Kafka提供了各种工具：
consumer 和 producer 工具允许消费和发布有关主题的消息
topic 工具允许 list, create, delete 和 describe 卡夫卡的主题。
broker 允许获取经纪人信息。
partition 工具允许获取分区和分区偏移。
group_offset 工具允许在Kafka中获取和重置偏移量。
配置
在中设置以下内容 .env 手动文件或导出
BOOTSTRAP_SERVERS=your_kafka_server
MCP_TRANSPORT=stdio地方发展
创建虚拟环境
# Using venv (built-in)
python3 -m venv .venv
# Activate the virtual environment
# On Windows
.venv\Scripts\activate
# On macOS/Linux
source .venv/bin/activate再进行
# Using pip
pip install -r requirements.txt
# Or using uv (faster)
uv pip install -r requirements.txt在终端/env中设置配置
BOOTSTRAP_SERVERS=
MCP_TRANSPORT=stdio运行应用程序
python3 src/main.py
# OR
uv run python3 src/main.py为了与服务器交互，
将以下配置添加到MCPO服务器的config.json文件中（例如，在Claude Desktop中）：
{
"mcpServers": {
"kafka-mcp": {
"command": "python3",
"args": ["/Users/I528600/Desktop/mcp/kafka-mcp/src/main.py"],
"env": {
"BOOTSTRAP_SERVERS": "localhost:9092",
"MCP_TRANSPORT": "stdio"
}
}
}
}示例提示
- 列出卡夫卡集群中的所有主题
- 在kafka集群中创建主题“我的kafka”
- 在集群中的“我的卡夫卡”主题下发布“来自mcp的你好”消息
- 消费卡夫卡集群中“我的卡夫卡”主题的2条消息
- 描述主题“我的卡夫卡”