Looking around the code base, I think it's only available in Scala (samza-core). That's ok. I can write the job in Scala. Need a little help on how to instantiate the object though...
On Thu, Dec 18, 2014 at 10:18 AM, Roger Hoover <[email protected]> wrote: > > 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 >> > >> >
