Single Message Transforms (SMT) implementation for routing messages
mvn clean install
Compile this JAR and put it into a path specified in plugin.path on each node running Kafka Connect, then restart the workers.
Add the following to the connector configuration:
"transforms": "outbox",
"transforms.outbox.type": "com.cloudera.kafka.connect.debezium.transformer.CustomDebeziumTopicTransformer",