> 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
