kafka-connect-transform-common

kafka-connect-transform-common copied to clipboard

Hi 👋 I'm using kafka topic to store messages with different avro schemas. Schema are stored within Confluent SR. I would like to send messages from the same topic to different destinations (BQ tables using Kafka Connect BQ sink) depending on the schema of the message. The SchemaNameToTopic seems to be promising, I would use it to change the topic name for every message depending on its schema, then the BQ sink connector would store the message within a table with the topic name.

Am I understanding it correctly?

If so, is there any config usage example of this transform please? Thanks!