Search code examples
apache-kafkaapache-kafka-connectdebezium

Change topic name used by Debezium connector

I would like to change the topic names using a Debezium connector, as I would like the topics not to be named with the default name "server.schema.table".

Solution

  • You can use various Kafka Connect transforms for setting the topic name.

    • InsertField to set static topic name
    • ExtractField + ExtractTopic for using some property of the record
    • RegexRouter for modifying the topic name based on a pattern ; for example, removing server.schema. prefix
    • One of your own