MCP server for Apache Kafka — built into Conduktor Console. Topics, consumer groups, schemas and cluster health, under your existing RBAC.
接入配置
选择客户端，复制配置，再按项目文档补齐环境变量。
claude mcp add conduktor --env CONDUKTOR_CONSOLE_URL='<CONDUKTOR_CONSOLE_URL>' --env CONDUKTOR_API_TOKEN='<CONDUKTOR_API_TOKEN>' -- npx -y @conduktor/mcp~/.codex/config.toml
[mcp_servers.conduktor]
command = "npx"
args = ["-y", "@conduktor/mcp"]
env = { CONDUKTOR_CONSOLE_URL = "<CONDUKTOR_CONSOLE_URL>", CONDUKTOR_API_TOKEN = "<CONDUKTOR_API_TOKEN>" }
# codex mcp add conduktor --env CONDUKTOR_CONSOLE_URL='<CONDUKTOR_CONSOLE_URL>' --env CONDUKTOR_API_TOKEN='<CONDUKTOR_API_TOKEN>' -- npx -y @conduktor/mcp~/.cursor/mcp.json
{
"mcpServers": {
"conduktor": {
"command": "npx",
"args": [
"-y",
"@conduktor/mcp"
],
"env": {
"CONDUKTOR_CONSOLE_URL": "<CONDUKTOR_CONSOLE_URL>",
"CONDUKTOR_API_TOKEN": "<CONDUKTOR_API_TOKEN>"
}
}
}
}.vscode/mcp.json
{
"servers": {
"conduktor": {
"type": "stdio",
"command": "npx",
"args": [
"-y",
"@conduktor/mcp"
],
"env": {
"CONDUKTOR_CONSOLE_URL": "<CONDUKTOR_CONSOLE_URL>",
"CONDUKTOR_API_TOKEN": "<CONDUKTOR_API_TOKEN>"
}
}
}
}~/.gemini/settings.json
{
"mcpServers": {
"conduktor": {
"command": "npx",
"args": [
"-y",
"@conduktor/mcp"
],
"env": {
"CONDUKTOR_CONSOLE_URL": "<CONDUKTOR_CONSOLE_URL>",
"CONDUKTOR_API_TOKEN": "<CONDUKTOR_API_TOKEN>"
}
}
}
}claude_desktop_config.json
{
"mcpServers": {
"conduktor": {
"command": "npx",
"args": [
"-y",
"@conduktor/mcp"
],
"env": {
"CONDUKTOR_CONSOLE_URL": "<CONDUKTOR_CONSOLE_URL>",
"CONDUKTOR_API_TOKEN": "<CONDUKTOR_API_TOKEN>"
}
}
}
}.trae/mcp.json
{
"mcpServers": {
"conduktor": {
"command": "npx",
"args": [
"-y",
"@conduktor/mcp"
],
"env": {
"CONDUKTOR_CONSOLE_URL": "<CONDUKTOR_CONSOLE_URL>",
"CONDUKTOR_API_TOKEN": "<CONDUKTOR_API_TOKEN>"
}
}
}
}需要的环境变量
CONDUKTOR_CONSOLE_URLCONDUKTOR_API_TOKEN
把占位值换成你自己的密钥；不要把密钥提交到代码仓库。