{
   "name": "postgres-sink-connector"
  ,"config": {
     "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector"
    ,"tasks.max": "1"
    ,"topics": "customers"
    ,"table.name.format": "customers"
    ,"connection.url": "jdbc:postgresql://postgres_target:5432/replicaDB?user=admin&password=jahUSV9ODVkZb2a14RoCcWYvfxbBLQ4Det86QZfrSHs="
    ,"transforms": "unwrap"
    ,"transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState"
    ,"transforms.unwrap.drop.tombstones": "false"
	,"transforms.unwrap.delete.handling.mode": "rewrite"
	,"transforms.InsertField.type": "org.apache.kafka.connect.transforms.InsertField$Value"
	,"transforms.ReplaceField.type": "org.apache.kafka.connect.transforms.ReplaceField$Value"
    ,"auto.create": "true"
    ,"auto.evolve": "true"
    ,"insert.mode": "upsert"
    ,"delete.enabled": "true"
    ,"pk.fields": "customerNumber"
    ,"pk.mode": "record_key"
    ,"transforms.route.type": "org.apache.kafka.connect.transforms.RegexRouter"
    ,"transforms.route.regex": "([^.]+)\\.([^.]+)\\.([^.]+)"
    ,"transforms.route.replacement": "$3"
	,"include.schema.changes": "true"
    ,"database.history.kafka.bootstrap.servers": "kafka1:9092,kafka2:9093,kafka3:9091"
    ,"database.history.kafka.topic": "schema-changes.classicmodels"
    ,"key.converter": "io.confluent.connect.avro.AvroConverter"
    ,"value.converter": "io.confluent.connect.avro.AvroConverter"
    ,"key.converter.schema.registry.url": "http://schemaRegistry:8081"
    ,"value.converter.schema.registry.url": "http://schemaRegistry:8081"
	}
}


