You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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!
The text was updated successfully, but these errors were encountered:
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!
The text was updated successfully, but these errors were encountered: