conduktor

Conduktor Platform

Conduktor は、Apache Kafka を中心に連携する 3 つの製品で構成されています。

• Console（conduktor/conduktor-console、ポート 8080）は、Kafka クラスターを監視・管理します。RBAC、トピックカタログ、モニタリング、セルフサービスフレームワーク、データ品質ポリシーを提供します。PostgreSQL が必要です。ライセンスがない場合は Community Edition として実行され、セルフサービスとデータ品質ポリシーは利用できず、ユーザー数、クラスター数、アラート数、マスキングポリシー数に上限があります。
• Gateway（conduktor/conduktor-gateway、ポート 6969）は、リクエストとレスポンスを傍受して変更する透過的な Kafka プロキシです。インターセプター、仮想クラスター、フィールドレベルの暗号化、データマスキング、トラフィック制御を提供します。クライアントは Kafka に直接接続するのではなく、Gateway に接続します。GATEWAY_LICENSE_KEY がないと起動しません（3.18 以降）。
• CLI（conduktor バイナリ）は、YAML の apply/get/delete によって Console と Gateway の両方のリソースを宣言的に管理する、kubectl スタイルのツールです。

Console と Gateway は別々のサービスです。Console から Gateway を管理できますが、それぞれ独立してデプロイされます。

バージョンの基準：このスキルは、Console 1.43～1.45、Gateway 3.17、CLI 0.7 向けに作成されました。ガードレールとコマンド形式は、Console 1.47.2、Gateway 3.21.1、CLI 0.9.2、Terraform provider 1.5.1（2026-09）で再検証済みです。バージョンに依存する詳細（環境変数、プラグインのオプション、追加された機能など）については、docs MCP で確認してください。

まず必ず読む

状態を変更するコマンドを実行する前に、references/guardrails.md を読んでください。ここでは、事前確認、エラー対応ガイド、CLI の状態と Terraform のデータ損失に関する落とし穴、シークレットの取り扱い、正常に動作するコマンド形式を説明しています。

Conduktor に関する質問では、references/mental-model.md を読み込み、製品の境界、Gateway のリソースモデル、仮想クラスター、セルフサービスフレームワークを理解してください。

AI アシスタントがよく間違える点については、references/anti-patterns.md を参照してください。

Conduktor と Kafka の用語対応については、references/terminology.md を参照してください。

ユースケース

プラットフォームエンジニア

やりたいこと	参照先
Console と Gateway をデプロイする（Docker、Helm、Kubernetes）	use-cases/platform/deploy-conduktor.md
Kafka データを暗号化またはマスキングする（フィールドレベル、ペイロード）	use-cases/platform/encrypt-kafka-data.md
データ品質ルールを適用する（CEL、JSON Schema）	use-cases/platform/enforce-data-quality.md
マルチテナンシーを設定する（仮想クラスター、ACL、サービスアカウント）	use-cases/platform/multi-tenancy.md
トラフィック制御と保護策を適用する（レート制限、トピックポリシー）	use-cases/platform/traffic-control.md
CLI と GitOps で自動化する（apply、CI/CD、状態管理）	use-cases/platform/gitops-automation.md
セルフサービスの GitHub CI/CD を設定する（ワークフロー、CODEOWNERS、トークン、ポリシー）— 公式の conduktor/self-service-template に基づく	use-cases/platform/self-service-github-cicd-cli.md
既存のクラスター、トピック、権限からセルフサービスをブートストラップする（公式テンプレートに一致するリポジトリを生成）	use-cases/platform/bootstrap-self-service-cli.md
Terraform でインフラストラクチャをコードとして管理する	use-cases/platform/terraform.md

アプリケーション開発者

次のことをしたい	読む
Conduktor を通じて Kafka を使い始める（接続、トピックの検出）	use-cases/app-developer/onboard-to-kafka.md
セルフサービスでトピックを作成する	use-cases/app-developer/create-topic.md
Gateway を通じて生成・消費する（クライアント設定、スキーマ）	use-cases/app-developer/produce-consume.md
別のチームのトピックへのアクセスをリクエストする	use-cases/app-developer/request-access.md

エージェントの動作

重要：まず検出してください。スキルファイルと CLI による検出で、ユーザーの実際の状態を把握できます。カバーされていない内容やバージョン依存の詳細については、docs MCP（ステップ 5）を使用してください。

ユーザーから Conduktor について尋ねられた場合、仕組みを説明するだけにとどめず、積極的に支援してください。

1. まず CLI で検出する — 事前チェック（guardrails.md §1：conduktor run whoami、ライセンスプラン）を実行し、該当するユースケースファイルを読み、その「Agent workflow」セクションにある conduktor get コマンドを実行します。CLI から実際の状態がわかり、ドキュメントから一般的な例がわかります。
2. 選択肢を提示して尋ねる — 検出結果を使い、自由回答形式の質問ではなく、具体的な選択肢を提示します。AskUserQuestion ツールが利用できる場合は、あらかじめ用意した選択肢（例：トピック名の候補、パーティション数、保持期間のプリセット）とともに使用します。番号付きの質問をまとめて聞くのではなく、一度に 1 つの質問をします。妥当なデフォルトを優先し、選択が本当に重要な場合にのみ質問してください。
3. すぐに使える出力を生成する — 検出で得た実際の名前を使って、完全な YAML、HCL、またはクライアント設定を作成します。実際の値を入れられる場合は、プレースホルダー付きのテンプレートを提示しないでください。
4. 確認を得てから実行する — まず conduktor apply -f <file> --dry-run を実行して出力を読みます。ライセンスに関する 403 エラー、または保持するつもりのリソースに対する Deleted (dry-run) の行がある場合は、停止してください（guardrails.md §2–3）。承認を得たら conduktor apply -f <file> を実行します。Terraform の場合は terraform plan を実行し、既存リソースの置換または破棄があれば停止してから、terraform apply を実行します。
5. 不明な点を調べる — スキルファイルと CLI による検出を確認した後、またはバージョン依存の詳細についてはすぐに、利用可能であれば search_conduktor_documentation ツール（Conduktor の MCP ドキュメントサーバー）を使用します。これらのファイルまたはドキュメントに記載されていない環境変数名、設定フィールド、API エンドポイントを決して作り出さないでください。MCP ツールを利用できない場合は、次の設定を追加するようユーザーに伝えてください：

   { "mcpServers": { "conduktor-docs": { "type": "url", "url": "https://docs.conduktor.io/mcp" } } }
   

CLI の実行には認証が必要です。コマンドが 401 エラーまたは接続エラーで失敗した場合は、ユーザーが CDK_BASE_URL + CDK_API_KEY（Console）、または CDK_GATEWAY_BASE_URL + CDK_GATEWAY_USER/CDK_GATEWAY_PASSWORD（Gateway）を設定できるよう支援してください。機能がライセンスで利用できないことを示す 403 はプランの制限であり、認証の問題ではありません。

インテントルーティング

ユーザーが次のキーワードに言及した場合、対応するファイルを読み込みます。

• error, 403, license, failed, deleted, data loss, state, dry-run → references/guardrails.md
• encrypt, mask, PII, GDPR, shield → use-cases/platform/encrypt-kafka-data.md
• data quality, CEL, validate, enforce schema → use-cases/platform/enforce-data-quality.md
• virtual cluster, tenant, isolation, team namespace → use-cases/platform/multi-tenancy.md
• rate limit, throttle, safeguard, quota, traffic → use-cases/platform/traffic-control.md
• deploy, Docker, Helm, Kubernetes, install → use-cases/platform/deploy-conduktor.md
• Gateway Community Edition, free Gateway, passthrough, cross-VPC, try Gateway without a cluster → use-cases/platform/gateway-community-edition.md
• conduktor CLI, apply, GitOps, CI/CD, pipeline, automation → use-cases/platform/gitops-automation.md
• GitHub Actions, CODEOWNERS, workflow, token scope, ResourcePolicy examples, onboarding app → use-cases/platform/self-service-github-cicd-cli.md
• bootstrap, self-service, adopt, migrate, ownership, reverse-engineer → use-cases/platform/bootstrap-self-service-cli.md
• Terraform, IaC, HCL, provider → use-cases/platform/terraform.md
• onboard, connect, credentials, getting started, bootstrap → use-cases/app-developer/onboard-to-kafka.md
• create topic, new topic, self-service topic → use-cases/app-developer/create-topic.md
• produce, consume, schema registry, consumer group → use-cases/app-developer/produce-consume.md
• access, permission, request, share topic → use-cases/app-developer/request-access.md