Hi all, Is there an easy way to get the number of partitions for a downstream topic? Or would I have to instantiate a Kafka producer myself in the Task.init().
I appreciate any suggestions. Thanks, Roger
Hi all, Is there an easy way to get the number of partitions for a downstream topic? Or would I have to instantiate a Kafka producer myself in the Task.init().
I appreciate any suggestions. Thanks, Roger