mcp-debezium

mcp-debezium

Debezium 用の Model Context Protocol サーバーです（Kafka Connect REST API 経由）。MCP 対応クライアント（Claude Desktop、Claude Code など）から、変更データキャプチャコネクターのステータス、設定、再起動、ライフサイクルを監視・管理できます。動作はすべてフラグで制御できます。

デフォルトでは安全です。読み取り専用で起動し、許可リストに含まれるコネクターのみに対象を限定できます。重要なコネクターの変更を保護し、コネクター設定の認証情報を伏せ字にし、明示的なオプトインがない限り削除を許可しません。

機能

• 監視 — ワーカー／クラスター情報、コネクター一覧、プラグイン、コネクターごとの設定、ステータス（失敗したタスクのトレースを含む）、トピック。
• 管理 — 作成／更新、一時停止／再開、コネクターまたは単一タスクの再起動。
• ライフサイクル — コネクターの削除（管理者）。
• アクセスモード — read-only → read-write → admin の順に権限を拡張します。各モードで、そのレベルを超えるツールが公開されることはありません。
• 認証情報の伏せ字化 — database.password やその他の秘密情報に該当する設定値は、結果を返す前に ***REDACTED*** に置き換えられます。
• セキュリティフラグ — コネクターの許可リスト、保護対象コネクター、削除の制御、ドライラン、JSON 監査ログ（下記参照）。

セキュリティモデル

懸念事項	フラグ	デフォルト	効果
サーバーが実行できる操作は？	DEBEZIUM_MODE	read-only	read-only では監視のみ、read-write ではライフサイクル管理が追加され、admin では削除が追加されます。モードの権限を超えるツールが登録されることはありません。
対象となるコネクターは？	DEBEZIUM_CONNECTOR_ALLOWLIST	(すべて)	設定すると、他のコネクターに対する操作は拒否されます。
常に読み取り専用となるコネクターは？	DEBEZIUM_PROTECTED_CONNECTORS	(なし)	調査はできますが、一時停止、再設定、削除はできません。
削除は可能ですか？	DEBEZIUM_ALLOW_DELETE	false	delete_connector の実行には、この設定と admin モードの両方が必要です。
Connect に変更を加えずにプレビューする	DEBEZIUM_DRY_RUN	false	書き込み／管理ツールは検証し、意図をログに記録してから終了します。
監査証跡	DEBEZIUM_AUDIT_LOG	true	保護対象の操作ごとに、stderr に JSON 形式の行を出力します。
対話形式の確認	(自動)	—	破壊的な操作や影響の大きい操作を実行する前に、MCP エリシテーションで人間に承認を求めます。エリシテーションに対応していないクライアントでは、*_ALLOW_* ゲートにフォールバックします。
認証情報の伏せ字化	(常に有効)	—	秘密情報に該当する設定値は、返す前に伏せ字化されます。

ツール

読み取り（read-only 以上）：cluster_info、list_connectors、list_connector_plugins、get_connector、get_connector_config、get_connector_status、get_connector_topics

書き込み（read-write 以上）：create_connector、update_connector_config、pause_connector、resume_connector、restart_connector、restart_task

管理者（admin）：delete_connector（DEBEZIUM_ALLOW_DELETE が必要）

クイックスタート — エージェントに追加する

npm で @dockndevai/mcp-debezium として公開されています。クローンやビルドは不要です。MCP クライアントが必要に応じて npx で実行します。read-only モードから開始してください。すべての変数については .env.example、クライアントごとの詳細ガイドは docs/CLIENTS.md を参照してください。

Claude Code（CLI）

claude mcp add debezium -e CONNECT_URL="http://localhost:8083" -e DEBEZIUM_MODE="read-only" -- npx -y @dockndevai/mcp-debezium

Claude Desktop · Cursor · Windsurf — 同じブロックを claude_desktop_config.json、.cursor/mcp.json、または ~/.codeium/windsurf/mcp_config.json に記述します。

{
  "mcpServers": {
    "debezium": {
      "command": "npx",
      "args": [
        "-y",
        "@dockndevai/mcp-debezium"
      ],
      "env": {
        "CONNECT_URL": "http://localhost:8083",
        "DEBEZIUM_MODE": "read-only"
      }
    }
  }
}

OpenAI Codex CLI — ~/.codex/config.toml に記述します。

[mcp_servers.debezium]
command = "npx"
args = ["-y", "@dockndevai/mcp-debezium"]
env = { CONNECT_URL = "http://localhost:8083", DEBEZIUM_MODE = "read-only" }

VS Code（GitHub Copilot、Agent mode） — .vscode/mcp.json に記述します。

{
  "servers": {
    "debezium": {
      "type": "stdio",
      "command": "npx",
      "args": [
        "-y",
        "@dockndevai/mcp-debezium"
      ],
      "env": {
        "CONNECT_URL": "http://localhost:8083",
        "DEBEZIUM_MODE": "read-only"
      }
    }
  }
}

プロンプトの例

• 「FAILED のコネクターと、その理由を教えてください。」
• 「pg-orders の失敗したタスクを再起動してください。」（read-write が必要です）
• 「mysql-inventory の設定を表示してください。」（認証情報は伏せ字で返されます）

ソースから実行する（開発）

上記の公開パッケージをお勧めします。クローンから実行するには：

npm install
npm run build
node dist/index.js   # with the environment variables set

開発

npm run dev
npm test          # security policy + config redaction
npm run typecheck

公開

このサーバーには、公式 MCP レジストリ用の server.json と、npm の所有権検証用の mcpName が含まれています。npm への公開と、MCP レジストリ、Smithery、Glama、Cursor、PulseMCP への掲載については、PUBLISHING.md を参照してください。

ライセンス

MIT