Change topic name used by Debezium connector

user_16606902 0
Viewed 1111

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".

debezium apache-kafka-connect apache-kafka
1 Answers

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
user_23086830
Related