mcpField
K
kafka-dataops-mcp

kafka-dataops-mcp

ローカル
github.com/Aguantarクラウド・インフラ04 週間前に更新
リポジトリ

kafka-dataops-mcp について

kafka-dataops-mcpは、Kafka運用チーム向けのMCPサーバーで、コンシューマーラグの診断やブローカーとトピックの健全性確認を行います。CDCパイプラインの運用事例に基づき、Flinkの障害やレプリケーションの問題を診断します。

主な機能

  1. 01コンシューマーラグと障害の診断
  2. 02トピック情報とレプリケーション確認
  3. 03ブローカーとクラスターの状態確認
  4. 04説明付きトピック一覧

活用シーン

  1. 01コンシューマーラグ増加の調査
  2. 02ブローカーとコントローラーの状態確認
  3. 03トピックのレプリケーション問題の発見

MCP 対応

MCPクライアントに、Kafkaのコンシューマーラグ、トピック、ブローカー状態、トピック一覧のツールを提供します。

設定

ローカルサーバーの設定はどのクライアントでも共通です。コピーしてクライアントの 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.0

ツール

ツール一覧はまだ取得されていません

ローカルサーバーのツールはマシン上で起動して初めて取得できます。メンテナーはまだツール一覧を提供していません。

詳細

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 クラッシュの検出：「アクティブなメンバーなし」＋増加するラグは、Flink ジョブの障害を示している可能性があります（MySQL の DELETE → Debezium の tombstone → Flink の NPE により 46 時間の停止が発生した事例に基づく）
  • チェックポイントとコンシューマーグループ：Flink では Kafka コンシューマーグループのリセットだけでは不十分であり、先にチェックポイントを削除する必要があることを警告します
  • 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"
      }
    }
  }
}

環境変数

変数デフォルト説明
KAFKA_BOOTSTRAP_SERVERSlocalhost:9092Kafka ブートストラップサーバー
KAFKA_COMMAND_TIMEOUT10コマンドのタイムアウト（秒）

ライセンス

MIT

コメント

Markdown 対応

MCP は初めてですか？

プロトコルの概要から最初のサーバーの導入まで、よくある疑問にまとめて答えます。

AI アプリケーションが外部のツールやデータソースに統一的な方法で接続するためのオープンなプロトコルです。クライアントはモデルとの対話を担い、MCP サーバーはツール・リソース・プロンプトテンプレートを提供します。標準メッセージでやり取りするため、1 つのサーバーを複数のクライアントで再利用できます。