mcp-debezium

Сервер на базе Model Context Protocol для Debezium (через Kafka Connect REST API). Он позволяет MCP-совместимому клиенту (Claude Desktop, Claude Code и т. д.) отслеживать и управлять коннекторами перехвата изменений данных — статус, конфигурация, перезапуски, жизненный цикл — при этом поведение полностью управляется флагами.

Безопасно по умолчанию: запускается в режиме «только чтение», может быть ограничено списком разрешённых коннекторов, защищает критически важные коннекторы от изменений, маскирует учётные данные в конфигурациях коннекторов и разрешает удаление только при явном согласии.

Возможности

• Мониторинг — информация о воркере/кластере, список коннекторов, плагины, конфигурация каждого коннектора, статус (с трассировками упавших задач) и топики.

• Управление — создание/обновление, пауза/возобновление, перезапуск коннектора или отдельной задачи.

• Жизненный цикл — удаление коннекторов (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