debezium_config.json

debezium_config.json

{
  "key.converter": "io.confluent.connect.avro.AvroConverter",
  "key.converter.schema.registry.url": <registry-url>,
  "value.converter": "io.clearstreet.debezium.EventConverter",
  "value.converter.schema.registry.url": <registry-url>,

  "transforms": "router,unwrap",
  "transforms.router.type": "io.clearstreet.debezium.EventRouter",
  "transforms.unwrap.type": "io.debezium.transforms.UnwrapFromEnvelope",
  "transforms.unwrap.drop.tombstones": true,

  "table.whitelist": ".*(events)$",
  "header.converter": "org.apache.kafka.connect.storage.SimpleHeaderConverter",
  "schema.registry.url": <registry-url>,
}