English Français العربية

io.github.Aguantar/kafka-dataops-mcp

السجل الرسمي أخرى

DataOps Kafka MCP server with consumer lag diagnosis and broker monitoring

الشيفرة المصدرية التوثيق

ماذا يمكنك أن تفعل مع io.github.Aguantar/kafka-dataops-mcp؟

  • kafka_consumer_lag — Consumer group lag with incident-pattern diagnosis
  • kafka_topic_info — Topic details with ISR/replication health checks
  • kafka_broker_status — Cluster health: brokers, controller, under-replicated partitions
  • kafka_list_topics — Topic catalog with built-in descriptions

التثبيت

أضف هذا إلى إعدادات MCP في عميلك (Claude Desktop: claude_desktop_config.json، وCursor: ‏.cursor/mcp.json، ويستخدم VS Code وغيره الصيغة نفسها «mcpServers»).

PYPI package kafka-dataops-mcp
Claude Code 
claude mcp add kafka-dataops-mcp -e 'KAFKA_BOOTSTRAP_SERVERS=<KAFKA_BOOTSTRAP_SERVERS>' -- uvx kafka-dataops-mcp==0.1.0
إعداد JSON (Claude Desktop وCursor وVS Code) 
{
    "mcpServers": {
        "kafka-dataops-mcp": {
            "command": "uvx",
            "args": [
                "kafka-dataops-mcp==0.1.0"
            ],
            "env": {
                "KAFKA_BOOTSTRAP_SERVERS": "<KAFKA_BOOTSTRAP_SERVERS>"
            }
        }
    }
}

متغيرات البيئة

  • KAFKA_BOOTSTRAP_SERVERS Kafka bootstrap servers

التوثيق

مأخوذ من ملف README للمشروع على GitHub ويُحدَّث أسبوعيًا. تفتح الروابط على GitHub.

المحتويات
  1. kafka-dataops-mcp
  2. Features
  3. Installation
  4. Usage with Claude Code
  5. Environment Variables
  6. License

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 diagnosis
  • kafka_topic_info — Topic details with ISR/replication health checks
  • kafka_broker_status — Cluster health: brokers, controller, under-replicated partitions
  • kafka_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

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

VariableDefaultDescription
KAFKA_BOOTSTRAP_SERVERSlocalhost:9092Kafka bootstrap servers
KAFKA_COMMAND_TIMEOUT10Command timeout in seconds

License

MIT

الأسئلة الشائعة

ما هو io.github.Aguantar/kafka-dataops-mcp؟

DataOps Kafka MCP server with consumer lag diagnosis and broker monitoring

كيف أثبّت io.github.Aguantar/kafka-dataops-mcp؟

يعمل على جهازك. في Claude Code: claude mcp add kafka-dataops-mcp -e 'KAFKA_BOOTSTRAP_SERVERS=<KAFKA_BOOTSTRAP_SERVERS>' -- uvx kafka-dataops-mcp==0.1.0. وفي العملاء الآخرين، الصق إعداد JSON من هذه الصفحة في إعدادات MCP الخاصة بهم.

هل يحتاج io.github.Aguantar/kafka-dataops-mcp إلى مفتاح API؟

لا يذكر إدراجه في السجل أي مفتاح أو سر إلزامي. قد تتطلب بعض الميزات حسابًا لدى الخدمة التي يتصل بها.

هل io.github.Aguantar/kafka-dataops-mcp مفتوح المصدر؟

نعم. شيفرته متاحة على GitHub بترخيص MIT.

من يصون io.github.Aguantar/kafka-dataops-mcp؟

ينشره Aguantar. يدرجه AI.tn لكنه لا يصونه ولا يوصي به.

من سجل MCP الرسمي. الإدراج ليس توصية: راجع شيفرة الخادم وصلاحياته قبل منحه الوصول إلى بياناتك.