Creating Kafka topic names dynamically in Replicate.

[David_Fergen]

To create a topic whose name is derived dynamically is achieved by creating a new column called $topic, then creating a transformation with an expression that sets the value you want to use as the topic name. 

Below is an example of having a topic per source table name : 

Create a global transformation that looks like this : 

NOTE : The type MUST be STRING(0), any other type, including strings of explicit lengths, cause your messages to go down a black hole.