MCP server for Apache Kafka — built into Conduktor Console. Topics, consumer groups, schemas and cluster health, under your existing RBAC.
Setup
Choose your client, copy the config, then fill in any required environment variables.
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>"
}
}
}
}Environment variables
CONDUKTOR_CONSOLE_URLCONDUKTOR_API_TOKEN
Replace the placeholders with your own credentials and keep them out of version control.