Hey Roger, You could instantiate a SystemAdmin for the topic in question. This interface has a getSystemStreamMetadata call that will give you partition information for arbitrary topics and systems.
Cheers, Chris On 12/17/14 4:51 PM, "Roger Hoover" <[email protected]> wrote: >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
