Server data from the Official MCP Registry
DataOps Kafka MCP server with consumer lag diagnosis and broker monitoring
About
DataOps Kafka MCP server with consumer lag diagnosis and broker monitoring
Security Report
Valid MCP server (1 strong, 4 medium validity signals). 3 known CVEs in dependencies (0 critical, 3 high severity) Package registry verified. Imported from the Official MCP Registry.
11 files analyzed · 4 issues found
Security scores are indicators to help you make informed decisions, not guarantees. Always review permissions before connecting any MCP server.
Permissions Required
This plugin requests these system permissions. Most are normal for its category.
What You'll Need
Set these up before or after installing:
Environment variable: KAFKA_BOOTSTRAP_SERVERS
How to Install
Add this to your MCP configuration file:
{
"mcpServers": {
"io-github-aguantar-kafka-dataops-mcp": {
"env": {
"KAFKA_BOOTSTRAP_SERVERS": "your-kafka-bootstrap-servers-here"
},
"args": [
"kafka-dataops-mcp"
],
"command": "uvx"
}
}
}Documentation
View on GitHubFrom the project's GitHub 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 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
Reviews
No reviews yet
Be the first to review this server!
More Data & Analytics MCP Servers
Toleno
Freeby Toleno · Developer Tools
Toleno Network MCP Server — Manage your Toleno mining account with Claude AI using natural language.
mcp-creator-python
Freeby mcp-marketplace · Developer Tools
Create, build, and publish Python MCP servers to PyPI — conversationally.
MarkItDown
Freeby Microsoft · Content & Media
Convert files (PDF, Word, Excel, images, audio) to Markdown for LLM consumption
MCP Marketplace
Freeby mcp-marketplace · Developer Tools
Search and install MCP servers from inside your AI client.
FinAgent
Freeby mcp-marketplace · Finance
Free stock data and market news for any MCP-compatible AI assistant.
mcp-creator-typescript
Freeby mcp-marketplace · Developer Tools
Scaffold, build, and publish TypeScript MCP servers to npm — conversationally