Re: Suppress DSL operator in stream api - 2.4.0

2019-11-22 Thread Kiran K
Hi Matthias, when we say 2.4.0, we just built the kafka from source and marked it as 2.4.0 for our internal reference. But I have taken latest Kafka 2.3.1 and tested & the issue still persists. pseudo code: .filter((key, value) -> ...) .groupByKey() .windowedBy(TimeWindows.of(Duration.ofMinutes

Anybody using uReplicator?

2019-11-13 Thread Kiran K
Hi, There are lot of articles which talk about known limitations of MirrorMaker 1 (MM1) and how Uber has overcome them with uReplicator. I am also aware that MM2 is getting ready. I have few questions: 1. When will MM2 be GA? 2. Anybody using uReplicator in production other than Uber? If yes, h