mcp-debezium

一个 Model Context Protocol 服务器，用于 Debezium（通过 Kafka Connect REST API）。它让支持 MCP 的客户端（Claude Desktop、Claude Code 等）监控和管理变更数据捕获连接器——状态、配置、重启、生命周期——其行为完全由标志控制。

默认安全：它以只读模式启动，可将作用范围限定为连接器允许列表，保护关键连接器不被修改，对连接器配置中的凭据进行脱敏，并将删除操作置于显式选择启用之后。

功能

• 监控 — 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 运行

{
  "mcpServers": {
    "debezium": {
      "command": "node",
      "args": ["/absolute/path/to/mcp-debezium/dist/index.js"],
      "env": {
        "CONNECT_URL": "http://connect:8083",
        "DEBEZIUM_MODE": "read-only",
        "DEBEZIUM_PROTECTED_CONNECTORS": "pg-prod-orders"
      }
    }
  }
}

示例提示

• “哪些连接器处于 FAILED 状态？为什么？”

• “重启 pg-orders 上失败的任务。”（需要 read-write）

• “显示 mysql-inventory 的配置。”（凭据返回时会被脱敏）

开发

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

发布

本服务器提供一份 server.json 用于官方 MCP 注册表，以及一个 mcpName 用于 npm 所有权验证。关于发布到 npm 以及上架 MCP 注册表、Smithery、Glama、Cursor 和 PulseMCP，请参阅 PUBLISHING.md。

许可证

MIT