To do this, I think I need a SystemFactory object so that I can call getAdmin() on it to get the SystemAdmin object you mentioned. Can you give me a pointer on how to do that in the task init()?
Thanks! On Wed, Dec 17, 2014 at 5:20 PM, Roger Hoover <[email protected]> wrote: > > Thanks, Chris! > > Sent from my iPhone > > > On Dec 17, 2014, at 5:10 PM, Chris Riccomini > <[email protected]> wrote: > > > > 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 > > >
