kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Damian Guy <damian....@gmail.com>
Subject Re: [Streams] Threading Frustration
Date Mon, 12 Dec 2016 17:45:36 GMT
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.rac200@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.guy@gmail.com> wrote:
>
> > Yep - that looks correct
> >
> > On Mon, 12 Dec 2016 at 17:18 Avi Flax <avi.flax@parkassist.com> wrote:
> >
> > >
> > > > On Dec 12, 2016, at 11:42, Damian Guy <damian.guy@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
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message