{
  "markdown": "# kafka-dataops-mcp\n\nmcp-name: io.github.Aguantar/kafka-dataops-mcp\n\nA DataOps-focused Kafka MCP server with consumer lag diagnosis and broker health monitoring. Diagnosis logic is based on actual CDC pipeline operational experience.\n\n## Features\n\n- **`kafka_consumer_lag`** — Consumer group lag with incident-pattern diagnosis\n- **`kafka_topic_info`** — Topic details with ISR/replication health checks\n- **`kafka_broker_status`** — Cluster health: brokers, controller, under-replicated partitions\n- **`kafka_list_topics`** — Topic catalog with built-in descriptions\n\n### Diagnosis based on real incidents\n\nThe diagnosis logic is not generic — it's based on actual operational experience:\n\n- **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)\n- **Checkpoint vs consumer group**: warns that Kafka consumer group reset alone is insufficient for Flink — checkpoints must be deleted first\n- **ClusterIdMismatch**: detects missing brokers and suggests Docker volume conflict as root cause\n- **ISR monitoring**: ISR < min.insync.replicas = write failures (critical)\n\n## Installation\n\n```bash\npip install kafka-dataops-mcp\n```\n\n## Usage with Claude Code\n\nAdd to your `.mcp.json`:\n\n```json\n{\n  \"mcpServers\": {\n    \"kafka\": {\n      \"command\": \"kafka-dataops-mcp\",\n      \"env\": {\n        \"KAFKA_BOOTSTRAP_SERVERS\": \"localhost:9092\"\n      }\n    }\n  }\n}\n```\n\n## Environment Variables\n\n| Variable | Default | Description |\n|----------|---------|-------------|\n| `KAFKA_BOOTSTRAP_SERVERS` | `localhost:9092` | Kafka bootstrap servers |\n| `KAFKA_COMMAND_TIMEOUT` | `10` | Command timeout in seconds |\n\n## License\n\nMIT\n",
  "bytes": 1725,
  "sha": "c004c5b78f3e39bb9d03e640c4601bc033509aa24e55636504e9387011dcc824",
  "repo_slug": "aguantar/kafka-mcp-server",
  "fonte": "repo",
  "truncated": false,
  "api": "https://agentalog.com/api/listings/mcp_io_github_aguantar_kafka_dataops_mcp_51707680/readme"
}