Lets AI models publish messages to and consume messages from Apache Kafka topics.
接入配置
选择客户端,复制配置,再按项目文档补齐环境变量。
claude mcp add kafka-server-pavanjava --env KAFKA_BOOTSTRAP_SERVERS='<KAFKA_BOOTSTRAP_SERVERS>' --env TOPIC_NAME='<TOPIC_NAME>' -- python -m venv venv~/.codex/config.toml
[mcp_servers.kafka-server-pavanjava]
command = "python"
args = ["-m", "venv", "venv"]
env = { KAFKA_BOOTSTRAP_SERVERS = "<KAFKA_BOOTSTRAP_SERVERS>", TOPIC_NAME = "<TOPIC_NAME>" }
# codex mcp add kafka-server-pavanjava --env KAFKA_BOOTSTRAP_SERVERS='<KAFKA_BOOTSTRAP_SERVERS>' --env TOPIC_NAME='<TOPIC_NAME>' -- python -m venv venv~/.cursor/mcp.json
{
"mcpServers": {
"kafka-server-pavanjava": {
"command": "python",
"args": [
"-m",
"venv",
"venv"
],
"env": {
"KAFKA_BOOTSTRAP_SERVERS": "<KAFKA_BOOTSTRAP_SERVERS>",
"TOPIC_NAME": "<TOPIC_NAME>"
}
}
}
}.vscode/mcp.json
{
"servers": {
"kafka-server-pavanjava": {
"type": "stdio",
"command": "python",
"args": [
"-m",
"venv",
"venv"
],
"env": {
"KAFKA_BOOTSTRAP_SERVERS": "<KAFKA_BOOTSTRAP_SERVERS>",
"TOPIC_NAME": "<TOPIC_NAME>"
}
}
}
}~/.gemini/settings.json
{
"mcpServers": {
"kafka-server-pavanjava": {
"command": "python",
"args": [
"-m",
"venv",
"venv"
],
"env": {
"KAFKA_BOOTSTRAP_SERVERS": "<KAFKA_BOOTSTRAP_SERVERS>",
"TOPIC_NAME": "<TOPIC_NAME>"
}
}
}
}claude_desktop_config.json
{
"mcpServers": {
"kafka-server-pavanjava": {
"command": "python",
"args": [
"-m",
"venv",
"venv"
],
"env": {
"KAFKA_BOOTSTRAP_SERVERS": "<KAFKA_BOOTSTRAP_SERVERS>",
"TOPIC_NAME": "<TOPIC_NAME>"
}
}
}
}.trae/mcp.json
{
"mcpServers": {
"kafka-server-pavanjava": {
"command": "python",
"args": [
"-m",
"venv",
"venv"
],
"env": {
"KAFKA_BOOTSTRAP_SERVERS": "<KAFKA_BOOTSTRAP_SERVERS>",
"TOPIC_NAME": "<TOPIC_NAME>"
}
}
}
}需要的环境变量
KAFKA_BOOTSTRAP_SERVERSTOPIC_NAME
把占位值换成你自己的密钥;不要把密钥提交到代码仓库。