samza-dev mailing list archives

Site index · List index
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