It is the same. The ruby code in this example is just calling into the Java API.
On Mon, 12 Dec 2016 at 17:40 Ali Akhtar <ali.rac...@gmail.com> wrote: > @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 > > >
