Hi , is there a feature in kafka connect which can route messages to a specific partition in a topic based on the table name. Eg : events from tableA goes to topic1.partition0 , tableB goes to topic1.partition1 etc
You should be able to set producer.override.partitioner.class, then define whatever behavior you want with your own implementation.
awesome , this was the property i was looking for . partitioner.class never worked. Will try that and close this thread
This topic was automatically closed 7 days after the last reply. New replies are no longer allowed.