yeenow123

Results 2 comments of yeenow123

Commit after all connected multicasted observables are finished processing a record

The issue seems to stem from `Observable.merge`. I tried `Observable.concat` and it seems to give me the functionality I need. I guess the ordering semantics between the two operators are...

Commit after all connected multicasted observables are finished processing a record

@Avasil I copied partial code and made some typos changing names. The `kafkaConsumerConfig` is passed into the `KafkaConsumerObservable` constructor. As with my EDIT on my previous comment, `concat` only seems...