kafka-dataops-mcp

Name: kafka-dataops-mcp
Author: Aguantar

本地服务

github.com/Aguantar云与基础设施04 周前更新

代码仓库

关于 kafka-dataops-mcp

kafka-dataops-mcp 面向 Kafka 运维团队，提供消费者延迟诊断以及 Broker 和主题健康检查。其诊断规则源自 CDC 流水线运维事故，涵盖 Flink 故障和副本问题。

主要功能

01消费者延迟与事故诊断
02主题详情和副本健康检查
03Broker 与集群状态检查
04附带说明的主题目录

适用场景

01排查消费者延迟增长
02检查 Broker 和控制器状态
03发现主题副本问题

MCP 相关

向 MCP 客户端提供 Kafka 消费者延迟、主题、Broker 状态和主题列表工具。

配置

本地服务的配置在各客户端中通用，复制后粘贴到客户端的 MCP 配置文件即可。

mcp.json · 通用配置

{
  "mcpServers": {
    "aguantar-kafka-dataops": {
      "command": "uvx",
      "args": [
        "kafka-dataops-mcp"
      ],
      "env": {
        "KAFKA_BOOTSTRAP_SERVERS": "<KAFKA_BOOTSTRAP_SERVERS>"
      }
    }
  }
}

启动命令uvx kafka-dataops-mcp

需要配置的环境变量

KAFKA_BOOTSTRAP_SERVERSKafka bootstrap servers

本地服务需要在你的电脑上安装运行环境（如 Node.js 18+）。各客户端的配置文件位置不同，请参考客户端文档。

安装包

pypikafka-dataops-mcp0.1.0stdio

工具

还没有获取到工具列表

本地服务需要在你的电脑上运行后才能读取工具，维护者暂未提供工具列表。

详细介绍

kafka-dataops-mcp

mcp-name: io.github.Aguantar/kafka-dataops-mcp

一款专注于 DataOps 的 Kafka MCP 服务，可诊断消费者延迟并监控代理健康状况。诊断逻辑基于实际 CDC 管道运维经验。

功能

kafka_consumer_lag — 消费者组延迟及事件模式诊断
kafka_topic_info — 主题详情及 ISR/副本健康检查
kafka_broker_status — 集群健康状况：代理、控制器、副本不足的分区
kafka_list_topics — 附带内置说明的主题目录

基于真实事件的诊断

诊断逻辑并非通用方案，而是基于实际运维经验：

Flink 崩溃检测：“no active members” + 延迟增长 = Flink 作业可能发生故障（根据一次持续 46 小时的中断事件：MySQL DELETE → Debezium 墓碑消息 → Flink NPE）
检查点与消费者组：警告仅重置 Kafka 消费者组对 Flink 来说并不足够——必须先删除检查点
ClusterIdMismatch：检测代理缺失，并提示 Docker 卷冲突可能是根本原因
ISR 监控：ISR < min.insync.replicas = 写入失败（严重）

安装

pip install kafka-dataops-mcp

在 Claude Code 中使用

添加到你的 .mcp.json：

{
  "mcpServers": {
    "kafka": {
      "command": "kafka-dataops-mcp",
      "env": {
        "KAFKA_BOOTSTRAP_SERVERS": "localhost:9092"
      }
    }
  }
}