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

Reply via email to