kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ofir Sharony <ofir.shar...@myheritage.com>
Subject Kafka Streams - ordering grouped messages
Date Wed, 01 Mar 2017 12:34:18 GMT
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.sharony@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>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message