π₯
io.github.Aguantar/kafka-dataops-mcp
DataOps Kafka MCP server with consumer lag diagnosis and broker monitoring
0 installs
Trust: 37 β Low
Healthcare
Ask AI about io.github.Aguantar/kafka-dataops-mcp
Powered by Claude Β· Grounded in docs
I know everything about io.github.Aguantar/kafka-dataops-mcp. Ask me about installation, configuration, usage, or troubleshooting.
0/500
Loading tools...
Reviews
Documentation
kafka-dataops-mcp
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.
Features
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 descriptions
Diagnosis based on real incidents
The diagnosis logic is not generic β it's based on actual operational experience:
- Flink crash detection: "no active members" + growing lag = likely Flink Job failure (based on a 50-hour outage caused by MySQL DELETE β Debezium tombstone β Flink NPE)
- Checkpoint vs consumer group: warns that Kafka consumer group reset alone is insufficient for Flink β checkpoints must be deleted first
- ClusterIdMismatch: detects missing brokers and suggests Docker volume conflict as root cause
- ISR monitoring: ISR < min.insync.replicas = write failures (critical)
Installation
pip install kafka-dataops-mcp
Usage with Claude Code
Add to your .mcp.json:
{
"mcpServers": {
"kafka": {
"command": "kafka-dataops-mcp",
"env": {
"KAFKA_BOOTSTRAP_SERVERS": "localhost:9092"
}
}
}
}
Environment Variables
| Variable | Default | Description |
|---|---|---|
KAFKA_BOOTSTRAP_SERVERS | localhost:9092 | Kafka bootstrap servers |
KAFKA_COMMAND_TIMEOUT | 10 | Command timeout in seconds |
License
MIT
