Hi, I have the following code on a stream:
.selectKey(...) .groupByKey(...) .reduce(...) The records arrived to the Reducer function in the same order they were consumed from Kafka I have implemented a TimestampExtractor, extracting the wanted timestamp from each record, but unfortunately this didn't have any effect on the order the messages were received in the Reducer. Any thoughts on that? Thanks, *Ofir Sharony* BackEnd Tech Lead Mobile: +972-54-7560277 <+972%2054-756-0277> | ofir.shar...@myheritage.com | www.myheritage.com MyHeritage Ltd., 3 Ariel Sharon St., Or Yehuda 60250, Israel <http://www.myheritage.com/> <https://www.facebook.com/myheritage> <https://twitter.com/myheritage> <http://blog.myheritage.com/> <https://www.youtube.com/user/MyHeritageLtd>
