Файл «sink-collections.json»¶

Ниже приведен пример конфигурационного файла «sink-collections.json», используемого для настройки и запуска sink-коннектора, обеспечивающего выгрузку данных из Apache Kafka в PostgreSQL.

json
{
 "name": "<prefix>-collections-sink-connector",
 "config": {
  "connector.class": "io.debezium.connector.jdbc.JdbcSinkConnector",
  "tasks.max": "1",
  "connection.url": "jdbc:postgresql://<postgres-host>:<postgres-port>/<prefix>_debezium_transfer_db",
  "connection.username": "<postgres-user>",
  "connection.password": "<postgres-password>",
  "topics": "<prefix>.public.dh_collections",
  "table.name.format": "dh_collections",
  "primary.key.fields": "id",
  "primary.key.mode": "record_key",
  "schema.evolution": "basic",
  "auto.create": "false",
  "auto.evolve": "false",
  "insert.mode": "upsert",
  "delete.enabled": "true",
  "key.converter": "org.apache.kafka.connect.json.JsonConverter",
  "key.converter.schemas.enable": "true",
  "transforms": "unwrap",
  "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
  "transforms.unwrap.delete.handling.mode": "drop",
  "transforms.unwrap.drop.tombstones": "false",
  "errors.tolerance": "all",
  "errors.log.enable": "true",
  "errors.log.include.messages": "true"
 }
}