mcp-debezium

Debezium 用の Model Context Protocol サーバーです（Kafka Connect REST API 経由）。MCP 対応クライアント（Claude Desktop、Claude Code など）で、change-data-capture コネクターの監視・管理 — ステータス、設定、再起動、ライフサイクル — ができ、動作はすべてフラグによって制御されます。

デフォルトで安全: 読み取り専用で起動し、コネクターの許可リストにスコープを限定でき、重要なコネクターを変更から保護し、コネクター設定内の資格情報を難読化し、削除は明示的なオプトインを必要条件としています。

機能

• 監視 — worker/クラスター情報、コネクター一覧、プラグイン、コネクターごとの設定、状態（失敗したタスクのトレースを含む）、トピック。

• 管理 — 作成/更新、一時停止/再開、コネクターまたは単一タスクの再起動。

• ライフサイクル — コネクターの削除（admin）。

• アクセスモード — read-only → read-write → admin と階層化され、各モードは自分のレベル以上のツールを公開しません。

• 資格情報の難読化 — database.password など、その他のシークレット形式の設定値は、結果が返る前に ***REDACTED*** に置き換えられます。

• セキュリティフラグ — コネクター許可リスト、保護対象コネクター、削除の制御、dry-run、JSON 監査ログ（下記参照）。

Related MCP server: Kafka MCP Server

セキュリティモデル

ツール

読み取り (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 が必要）

MCPクライアントで利用する

Claude Code、Claude Desktop、Cursor、OpenAI Codex CLI、Windsurf、VS Code (Copilot)、およびその他のあらゆるMCPクライアントで動作します。クライアントごとの設定は docs/CLIENTS.md を参照してください。

インストール

npm install
npm run build

Claude Desktop / Claude Code で実行

GXP1 GXP2

プロンプト例

• "どのコネクターが FAILED ですか。その理由は？"

• "pg-orders で失敗したタスクを再起動してください。"（read-write が必要）

• "mysql-inventory の設定を表示してください。"（資格情報は難読化されて返ります）

開発

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