Создание и подключение коннекторов Debezium¶

Для настройки Debezium необходимо создание и подключение коннекторов:

• dh-collections-service-collection-connector;
• dh-documents-service-documents-connector;
• dh-documents-service-items-connector;
• dh-favorites-service-dhfavorite-connector;
• dh-folders-service-folder-connector;
• dh-relations-service-relation-connector.

В приведенных примерах используется базовый объект конфигурации. Файл коннектора не должен содержать поля «name» и «config».

Пример корректного формата файла коннектора:

{
  "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
  "plugin.name": "pgoutput"
}

Данный формат файла коннектора недопустим:

{
  "name": "dh-collections-service-collection-connector",
  "config": {
    "connector.class": "io.debezium.connector.postgresql.PostgresConnector"
  }
}

Для применения конфигурации необходимо использовать метод:

PUT /connectors/<имя-коннектора>/config