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

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

{.listing} 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" } }