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:29:50 GMT
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