MCP server for Apache Kafka — monitor & manage clusters, topics, and consumer groups (with lag), with security modes and access-control flags.
接入配置
选择客户端，复制配置，再按项目文档补齐环境变量。
claude mcp add kafka --env KAFKA_BROKERS='<KAFKA_BROKERS>' -- npx -y @dockndevai/mcp-kafka~/.codex/config.toml
[mcp_servers.kafka]
command = "npx"
args = ["-y", "@dockndevai/mcp-kafka"]
env = { KAFKA_BROKERS = "<KAFKA_BROKERS>" }
# codex mcp add kafka --env KAFKA_BROKERS='<KAFKA_BROKERS>' -- npx -y @dockndevai/mcp-kafka~/.cursor/mcp.json
{
"mcpServers": {
"kafka": {
"command": "npx",
"args": [
"-y",
"@dockndevai/mcp-kafka"
],
"env": {
"KAFKA_BROKERS": "<KAFKA_BROKERS>"
}
}
}
}.vscode/mcp.json
{
"servers": {
"kafka": {
"type": "stdio",
"command": "npx",
"args": [
"-y",
"@dockndevai/mcp-kafka"
],
"env": {
"KAFKA_BROKERS": "<KAFKA_BROKERS>"
}
}
}
}~/.gemini/settings.json
{
"mcpServers": {
"kafka": {
"command": "npx",
"args": [
"-y",
"@dockndevai/mcp-kafka"
],
"env": {
"KAFKA_BROKERS": "<KAFKA_BROKERS>"
}
}
}
}claude_desktop_config.json
{
"mcpServers": {
"kafka": {
"command": "npx",
"args": [
"-y",
"@dockndevai/mcp-kafka"
],
"env": {
"KAFKA_BROKERS": "<KAFKA_BROKERS>"
}
}
}
}.trae/mcp.json
{
"mcpServers": {
"kafka": {
"command": "npx",
"args": [
"-y",
"@dockndevai/mcp-kafka"
],
"env": {
"KAFKA_BROKERS": "<KAFKA_BROKERS>"
}
}
}
}需要的环境变量
KAFKA_BROKERS
把占位值换成你自己的密钥；不要把密钥提交到代码仓库。