Файл «source-relations.json»¶

Ниже приведен пример конфигурационного файла «source-relations.json», используемого для настройки и запуска source-коннектора Debezium PostgreSQL.

json
{
 "name": "<prefix>-relations-connector",
 "config": {
  "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
  "plugin.name": "pgoutput",
  "database.hostname": "<postgres-host>",
  "database.port": "<postgres-port>",
  "database.user": "<postgres-user>",
  "database.password": "<postgres-password>",
  "database.dbname": "<prefix>_dh_relations_db",
  "topic.prefix": "<prefix>",
  "table.include.list": "public.dh_relations",
  "heartbeat.interval.ms": "5000",
  "slot.name": "<prefix>_dh_relations_db",
  "publication.name": "<prefix>_dh_relations_db_publication",
  "publication.autocreate.mode": "filtered",
  "key.converter": "org.apache.kafka.connect.json.JsonConverter",
  "key.converter.schemas.enable": "true",
  "snapshot.mode": "always"
 }
}