Hi, The TimestampExtractor won't effect the order the records arrive in. It just provides a way for developers to use a timestamp other than the default.
Thanks, Damian On Wed, 1 Mar 2017 at 12:34 Ofir Sharony <ofir.shar...@myheritage.com> wrote: > 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> <+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> >
