mcp-debezium

Un servidor Model Context Protocol para Debezium (a través de la API REST de Kafka Connect). Permite que un cliente compatible con MCP (Claude Desktop, Claude Code, etc.) supervise y gestione conectores de captura de cambios de datos — estado, configuración, reinicios, ciclo de vida — con un comportamiento totalmente controlado por flags.

Seguro por defecto: arranca en modo solo lectura, puede restringirse a una lista de conectores permitidos, protege los conectores críticos frente a modificaciones, oculta las credenciales en las configuraciones de los conectores y supedita la eliminación a una aceptación explícita.

Características

• Supervisión — información de worker/cluster, lista de conectores, plugins, configuración por conector, estado (con trazas de tareas fallidas) y temas.

• Gestión — crear/actualizar, pausar/reanudar, reiniciar el conector o una sola tarea.

• Ciclo de vida — eliminar conectores (admin).

• Modos de acceso — read-only → read-write → admin, por niveles, de modo que un modo nunca exponga herramientas por encima de su nivel.

• Ocultación de credenciales — database.password y otros valores de configuración con forma de secreto se sustituyen por ***REDACTED*** antes de devolver los resultados.

• Flags de seguridad — lista de intersecados de conectores, conexos protegidos, restricción de eliminación, simulación y registro de auditoría JSON (consulte más abajo).

Related MCP server: Kafka MCP Server

Modelo de seguridad

Herramientas

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

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

Administración (admin): delete_connector (requiere DEBEZIUM_ALLOW_DELETE)

Uso con tu cliente MCP

Funciona con Claude Code, Claude Desktop, Cursor, OpenAI Codex CLI, Windsurf, VS Code (Copilot) y cualquier otro cliente MCP — consulta docs/CLIENTS.md para la configuración específica por cliente.

Instalación

npm install
npm run build

Ejecutar con 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"
      }
    }
  }
}

Ejemplos de preguntas

• "¿Qué conectores están en FAILED y por qué?"

• "Reinicia la tarea fallida en pg-orders." (necesita read-write)

• "Muestra la configuración de mysql-inventory." (las credenciales se devuelven ocultas)

Desarrollo

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

Publicación

Este servidor incluye un server.json para el registro oficial de MCP y un mcpName para validar la propiedad en npm. Consulta PUBLISHING.md para publicar en npm y aparecer en el registro MCP, Smithery, Glama, Cursor y PulseMCP.

Licencia

MIT