@Damian, In the Java equivalent of this, does each KStream / KStreamBuilder.stream() invocation create its own topic group, i.e its own thread?
On Mon, Dec 12, 2016 at 10:29 PM, Damian Guy <damian....@gmail.com> wrote: > 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 >
