Conduktor

Conduktor MCP

Kafka 環境を AI アシスタントに管理させましょう。

クラスターを眺めるだけのチャットウィンドウではありません。エージェントが、あなたのものでも私たちのものでも、稼働中のすべてのクラスターで実際に何が起きているかを把握し、対応するための手段です。誰も利用していないトピックを整理し、コストを支出したチームに割り当て、来月期限切れになる証明書を見つけ、午前3時に失敗したコネクターを再起動し、担当者が退職したトピックにラベルを付けます。

MCP エンドポイントはConduktor Consoleに組み込まれています。デプロイは不要で、新たにセキュリティ対策を施す必要もありません。アシスタントは、すでに運用している RBAC、監査証跡、所有権モデルを引き継ぎます。

まずは試してみる

手元に Kafka がなくても大丈夫です。demo/を使えば、トピック、トラフィック、意図的に遅延させたコンシューマーグループを用意したクラスター、Console、MCP エンドポイントをdocker compose up -dで起動できます。

セットアップ

Console で Personal Access Token を作成し、MCP クライアントを自分の Console に接続します。

{
  "mcpServers": {
    "conduktor": {
      "command": "npx",
      "args": ["-y", "@conduktor/mcp"],
      "env": {
        "CONDUKTOR_CONSOLE_URL": "https://console.acme-corp.com",
        "CONDUKTOR_API_TOKEN": "your-personal-access-token"
      }
    }
  }
}

/api/mcpは自動で追加されます。末尾にすでに含まれている URL を貼り付けても機能します。

{
  "mcpServers": {
    "conduktor": {
      "command": "npx",
      "args": [
        "mcp-remote",
        "https://console.acme-corp.com/api/mcp",
        "--header",
        "Authorization: Bearer ${CONDUKTOR_API_TOKEN}"
      ],
      "env": { "CONDUKTOR_API_TOKEN": "your-personal-access-token" }
    }
  }
}

アシスタントに質問できること

英語で質問すると、ドキュメントではなく、実際の環境に基づいた回答が得られます。

1か月間消費されていないトピックと、その作成者を教えてください。 前四半期に payments チームが費やしたコストと、その要因を教えてください。 このコンシューマーグループが停止しています。処理を妨げているメッセージは何ですか？ 3月より前に期限切れになる証明書と、それぞれの所有者を教えてください。 これらのトピックには所有者がいません。リネージから担当すべき人を特定できますか？

これらは単なるデモではありません。それぞれが以下のツールに対応しており、エージェントが無人で実行できるタスクにも対応しています。

回答から運用へ

同じカタログを、2種類の呼び出し元が利用します。Claude Code、Cursor、スクリプト、社内開発者プラットフォームなどのツールと、スケジュールまたは監査ログイベントをきっかけに、独自のマシン ID で実行されるConsole 内のエージェントです。

後者によって、これは単なるチャットボットではなくなります。エージェントとは、タスクと ID、そして範囲を限定したツール一式を組み合わせたものです。月曜日の午前9時や、コネクターの失敗と同時に起動し、問題に取り組み、対応可能なレポートや提案、あるいは実行を提案してあなたの承認を待つ変更を返します。

各実行の全過程が記録されます。プロンプト、各ツール呼び出し、トークン、結果がすべて対象です。これをチケットに添付したり、監査担当者に提出したりできます。

ツール

コントロールプレーン全体をカバーする31個のツールです。大半は読み取り専用ですが、書き込みを行うツールもあり、その数は増えています。

クラスター

トピック

メッセージ

コンシューマーグループ

スキーマ

Connect、Gateway

アクセス、ID、ガバナンス、コスト

セキュリティがあるからこそ実現できます

エージェントに本番環境への実アクセスを許可できるのは、境界がすでに定められ、呼び出しごとに適用されているからです。

ユーザー本人として実行されます。 すべての呼び出しには Console トークンが含まれ、そのユーザーの RBAC 権限で実行されます。エージェントが参照できるのは、その所有者が参照できるクラスターだけです。所有者のアクセス権を取り消すと、エージェントのアクセス権も同時に失われます。

データプレーンではなく、コントロールプレーンです。 モデルに渡されるのは、トピック、設定、オフセット、グループ、スキーマ、リネージ、コストなどのメタデータです。タスクでレコードを読み取るツールが明示的に必要でない限り、レコードが Kafka の外に出ることはありません。

すべて監査されます。 すべての呼び出しが Console の監査ログに記録され、実行した ID に関連付けられます。

ドキュメント

• MCP サーバーガイド
• 製品ページ
• Console のドキュメント

このリポジトリの内容

@conduktor/mcp として公開されているランチャー、このドキュメント、レジストリのメタデータが含まれています。サーバー自体は Console 内で実行されます。サーバーのバグについては Conduktor サポートにお問い合わせください。ランチャーやドキュメントについては、こちらで issue を作成してください。