Kafka Dataops Mcp
Connects Claude to Kafka clusters for DataOps monitoring and troubleshooting. Exposes four tools: check consumer group lag with diagnostic patterns, inspect topic configuration and ISR health, view broker status and under-replicated partitions, and list topics. The diagnostics aren't generic, they're based on real production incidents like detecting Flink crashes from inactive consumers plus growing lag, or flagging ClusterIdMismatch from Docker volume conflicts. Reach for this when you're debugging CDC pipelines or need Claude to assess cluster health and consumer lag issues. Configuration is straightforward, just point it at your bootstrap servers via environment variables.
- tools
- 4
- transport
- STDIO
- env var
- 1
- last updated
- Mar 19, 2026
Tools
4 toolsPublic tool metadata for what this MCP can expose to an agent.
kafka_consumer_lagConsumer group lag with incident-pattern diagnosis
Consumer group lag with incident-pattern diagnosis
No parameter schema in public metadata yet.
kafka_topic_infoTopic details with ISR/replication health checks
Topic details with ISR/replication health checks
No parameter schema in public metadata yet.
kafka_broker_statusCluster health: brokers, controller, under-replicated partitions
Cluster health: brokers, controller, under-replicated partitions
No parameter schema in public metadata yet.
kafka_list_topicsTopic catalog with built-in descriptions
Topic catalog with built-in descriptions
No parameter schema in public metadata yet.
Sponsors
Agent CaffeineSponsoredClose your lid, come back to finished work
SnugSponsoredThe clipboard manager for the AI eraPromote your product hereReach 125k+ visitors monthly
WaxSponsoredBlock anything with supervision, without erasing your iPhonePromote your product hereReach 125k+ visitors monthly
knobsSponsoredSee your site on any phone, any day, in any languageConfiguration
KAFKA_BOOTSTRAP_SERVERSKafka bootstrap servers
Readme
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 46-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
Details
- Repository
- github.com/aguantar/kafka-mcp-server
- Package
kafka-dataops-mcp- Transport
- STDIO
- Registry
- MCP registry, active