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 18:18:30 GMT
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 <roger.hoover@gmail.com>
wrote:
>
> 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
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message