kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ali Akhtar <ali.rac...@gmail.com>
Subject Re: [Streams] Threading Frustration
Date Mon, 12 Dec 2016 17:40:28 GMT
@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