Yep - that looks correct On Mon, 12 Dec 2016 at 17:18 Avi Flax <avi.f...@parkassist.com> wrote:
> > > On Dec 12, 2016, at 11:42, Damian Guy <damian....@gmail.com> wrote: > > > > If you want to split these out so that they can run in parallel, then you > > will need to create a new stream for each topic. > > > Just to make sure I’m understanding this, does this code change look right? > > From this: > > ```ruby > topic_names = SDP::Config.topic_names(config).to_java(:string) > bay_events = builder.stream key_serde, val_serde, topic_names > # etc > ``` > > > To this: > > ```ruby > SDP::Config.topic_names(config).each do |topic_name| > bay_events = builder.stream key_serde, val_serde, topic_name > # etc > end > ``` > > > I hope so! > > Thanks! > Avi
