| Message view | « Date » · « Thread » |
|---|---|
| Top | « Date » · « Thread » |
| From | Chris Riccomini <criccom...@linkedin.com.INVALID> |
| Subject | Re: How to get number of partitions for a downstream topic? |
| Date | Thu, 18 Dec 2014 01:10:33 GMT |
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" <roger.hoover@gmail.com> 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 | |
| Mime |
|
| View raw message | |