DataOps Kafka MCP server with consumer lag diagnosis and broker monitoring
mcp-name: io.github.Aguantar/kafka-dataops-mcp
A DataOps-focused Kafka MCP server with consumer lag diagnosis and broker health monitoring. Diagnosis logic is based on actual CDC pipeline operational experience.
kafka_consumer_lag — Consumer group lag with incident-pattern diagnosiskafka_topic_info — Topic details with ISR/replication health checkskafka_broker_status — Cluster health: brokers, controller, under-replicated partitionskafka_list_topics — Topic catalog with built-in descriptionsThe diagnosis logic is not generic — it's based on actual operational experience:
pip install kafka-dataops-mcp
Add to your .mcp.json:
{
"mcpServers": {
"kafka": {
"command": "kafka-dataops-mcp",
"env": {
"KAFKA_BOOTSTRAP_SERVERS": "localhost:9092"
}
}
}
}
| Variable | Default | Description |
|---|---|---|
KAFKA_BOOTSTRAP_SERVERS | localhost:9092 | Kafka bootstrap servers |
KAFKA_COMMAND_TIMEOUT | 10 | Command timeout in seconds |
MIT
Source-derived launch command. Check the maintainer’s required arguments and credentials before running:
uvx kafka-dataops-mcpMerge this template into ~/Library/Application Support/Claude/claude_desktop_config.json. Keep existing servers. Add any arguments, credentials, and permissions required by the maintainer; this template has not been install-tested.
{
"mcpServers": {
"io-github-aguantar-kafka-dataops-mcp": {
"command": "uvx",
"args": [
"kafka-dataops-mcp"
]
}
}
}Restart Claude Desktop completely for changes to take effect. Confirm the server appears connected in the client’s tool list, then try a read-only example from its documentation.
Claude Desktop setup referencekafka-dataops-mcppypiio.github.Aguantar/kafka-dataops-mcp works with any MCP-compatible client. Copy the config snippet from the Configuration section above and add it to the file shown for your client, then restart the application.
~/Library/Application Support/Claude/claude_desktop_config.jsonRestart Claude Desktop completely for changes to take effect.~/.cursor/mcp.jsonRestart Cursor for changes to take effect..vscode/mcp.jsonReload VS Code window for changes to take effect.~/.codeium/windsurf/mcp_config.jsonRestart Windsurf for changes to take effect..mcp.jsonSave at the project root, then start Claude Code in that project and review the MCP server approval prompt. Keep real credentials out of shared files.