Hi Elias,

- out of order records: the timestamp is that of the out of order record, i.e., 
time goes backwards sometimes
- joins: the same, the timestamp could be that of either record.

We'll update the docs, thanks for your question.

Eno

> On 17 Sep 2016, at 00:43, Elias Levy <fearsome.lucid...@gmail.com> wrote:
> 
> On Sat, Sep 10, 2016 at 9:17 AM, Eno Thereska <eno.there...@gmail.com>
> wrote:
> 
>> 
>> For aggregations, the timestamp will be that of the latest record being
>> aggregated.
>> 
> 
> How does that account for out of order records?
> 
> What about kstream-kstream joins?  The output from the join could be
> triggered by a record received from either stream depending on the order
> they are received and processed.  If the timestamp of the output is just
> the timestamp of the latest received record, then it seems that the
> timestamp could be that of either record.  Although I suppose that the best
> effort stream synchronization effort that Kafka Streams attempts means that
> usually the timestamp will be that of the later record.

Reply via email to