samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Roger Hoover <roger.hoo...@gmail.com>
Subject Re: How to get number of partitions for a downstream topic?
Date Thu, 18 Dec 2014 01:20:58 GMT
Thanks, Chris!

Sent from my iPhone

> On Dec 17, 2014, at 5:10 PM, Chris Riccomini <criccomini@linkedin.com.INVALID>
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" <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