Kafka Dataops Mcp

io.github.Aguantar由 GitHub 帳號 Aguantar 發布v0.1.0更新於 Oct 24, 2026

DataOps Kafka MCP server with consumer lag diagnosis and broker monitoring

已驗證STDIO僅桌面資料庫安全與監控

概覽

AI 產生的概覽

一個在本機執行的 Kafka DataOps MCP 伺服器，讓助理查看消費群組延遲、主題與 Broker 健康狀態，並提供基於真實事故的診斷提示。

可以做什麼
檢查消費群組：讀取延遲，並針對停滯的管線給出事故模式診斷提示，包括 Flink 相關故障模式與 checkpoint 警告。檢視主題：取得主題詳情並做 ISR 與副本健康檢查，列出含內建描述的主題目錄。檢查叢集：回報 Broker、控制器與副本不足的分割區。
適用情境
適合在維運 Kafka 或 CDC 管線時使用，讓助理在故障排查與日常巡檢中協助分析消費延遲、副本問題與 Broker 健康狀況。
執行需求
以 Python 套件形式透過 pip 安裝並在本機以 stdio 執行。需要能連線 Kafka 叢集的網路，透過環境變數 KAFKA_BOOTSTRAP_SERVERS 設定（預設 localhost:9092）；KAFKA_COMMAND_TIMEOUT 設定指令逾時秒數。
安裝前請注意
它會連線你的 Kafka 叢集並讀取消費群組、主題與 Broker 狀態等維運中繼資料，請只指向你有權檢查的叢集。未宣告任何驗證方式，存取控制取決於叢集與網路設定。

安裝

在 SourceWeft 中

  1. 開啟 儀表板中的 Kafka Dataops Mcp，將其新增到工作區。
  2. 為需要使用其工具的對話啟用該服務。

Desktop only，透過 STDIO。 STDIO 服務會啟動本機處理程序，因此需要 SourceWeft 桌面主機。

其他 MCP 客戶端

參照 儲存庫 中的啟動說明。

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 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

bash
pip install kafka-dataops-mcp

Usage with Claude Code

Add to your .mcp.json:

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

來源：README.md，提交 6b30d7a

工具

0
SourceWeft 尚未在沙箱中啟動過該軟體包，因此其工具未知。

版本歷史

1
  1. v0.1.0最新Sep 16, 2026

評分

已滿足適用檢查項的 50%

該評分衡量此收錄條目的完整程度，依據註冊中心條目、端點與公開來源計算得出。它不是對伺服器本身的評價，也不表示伺服器安全或目前可用：可連通性是帶日期的檢查結果，評分也不包含安裝量或使用者評價。

  • 近 30 天內可連通25 分

    請保持端點能夠回應 MCP 握手；SourceWeft 每 30 天探測一次。

  • 已宣告認證方式10 分

    請在註冊中心條目中宣告憑證請求標頭，或保持端點能夠回應探測，以便判定其認證方式。

  • 已列出工具15 分

    請讓伺服器在無憑證時回應 tools/list，或發布可在沙箱中無憑證啟動的軟體包。

  • 描述必需15 分
  • 圖示10 分
  • 文件15 分
  • 授權條款10 分