Настройки Debezium¶
Работают следующие условия формирования сообщений Debezium:
- Отдельный топик на каждый базовый класс или необходимый системный класс в каждом сервисе.
- Структура сообщения «UpdateObjectAttributesDebeziumDto».
Параметры настроек Debezium
| Поле в настройках Debezium | Описание | Пример |
|---|---|---|
| name | Формируется по шаблону: {Наименование сервиса}-{Базовый класс объекта/системный класс объекта} | "name": "dh-documents-service-document", "name": "dh-files-service-file", |
| topic.prefix | Префикс топика Apache Kafka, в который публикуются изменения в таблице, формируется по шаблону: {dev/test}-dh-es-{Наименование сервиса}-{Базовый класс объекта/системный класс объекта}, где: · "es" обозначает назначение топика для индексирования объектов в ES; · {Наименование сервиса} - отделяет объекты одного базового класса, хранящихся в разных сервисах; · {Базовый класс объекта/системный класс объекта} - отделяет объекты разных базовых классов, хранящихся в одном сервисе |
"topic.prefix": "dev-dh-es-dh-documents-service-document", |
| database.hostname | Адрес сервера БД | "database.hostname": "172.19.91.150" |
| database.dbname | Наименование БД | "database.dbname" : "dev_dh_object_db" |
| table.include.list | Таблица, из которой считываются изменения Debezium. Формат: {схема}.{таблица}. Может быть указано несколько таблиц через запятую | "table.include.list": "public.dh_object", |