mcp-debezium

Ein Model Context Protocol-Server für Debezium (über die Kafka Connect REST-API). Er ermöglicht einem MCP-fähigen Client (Claude Desktop, Claude Code usw.) Change-Data-Capture-Connectors zu überwachen und zu verwalten — Status, Konfiguration, Neustarts, Lebenszyklus — wobei das Verhalten vollständig über Flags gesteuert wird.

Sicherheitsstandard: Er startet im Nur-Lese-Modus, kann auf eine Allowlist von Connectors eingeschränkt werden, schützt kritische Connectors vor Änderung, maskiert Zugangsdaten in Connector-Konfigurationen und macht das Löschen nur mit expliziter Freigabe möglich.

Features

• Überwachung — Worker-/Cluster-Informationen, Connector-Liste, Plugins, Konfiguration pro Connector, Status (mit Traces fehlgeschlagener Tasks) und Topics.

• Verwaltung — Erstellen/Aktualisieren, Pausieren/Fortsetzen, Neustart eines Connectors oder eines einzelnen Tasks.

• Lebenszyklus — Löschen von Connectors (nur Admin).

• Zugriffsmodi — read-only → read-write → admin, abgestimmt, sodass ein Modus niemals Tools oberhalb seiner Stufe bereitstellt.

• Maskierung von Zugangsdaten — database.password und andere geheim im Wert gehaltene Konfigurationswerte werden vor der Rückgabe der Ergebnisse durch ***REDACTED*** ersetzt.

• Sicherheitsflags — Connector-Allowlist, geschützte Connectors, Lösch-Hürde, Trockenlauf und JSON-Auditprotokoll (siehe unten).

Related MCP server: Kafka MCP Server

Sicherheitsmodell

Tools

Lesen (read-only+): cluster_info, list_connectors, list_connector_plugins, get_connector, get_connector_config, get_connector_status, get_connector_topics

Schreiben (read-write+): create_connector, update_connector_config, pause_connector, resume_connector, restart_connector, restart_task

Admin (admin): delete_connector (benötigt DEBEZIUM_ALLOW_DELETE)

Verwendung mit deinem MCP-Client

Funktioniert mit Claude Code, Claude Desktop, Cursor, OpenAI Codex CLI, Windsurf, VS Code (Copilot) und jedem anderen MCP-Client — siehe docs/CLIENTS.md für die Einrichtung pro Client.

Installation

npm install
npm run build

Ausführen mit 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"
      }
    }
  }
}

Beispiel-Anfragen

• „Welche Connectors haben den Status FAILED und warum?“

• „Starte den fehlgegangenen Task auf pg-orders neu.“ (erfordert read-write)

• „Zeig mir die Konfiguration für mysql-inventory.“ (Zugangsdaten werden maskiert zurückgegeben)

Entwicklung

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

Veröffentlichen

Dieser Server enthält die server.json für die offizielle MCP-Registry und einen mcpName für die npm-Besitz-Validierung. Siehe PUBLISHING.md für das Veröffentlichen auf npm und die Auflistung in der MCP-Registry, Smithery, Glama, Cursor und PulseMCP.

Lizenz

MIT