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.
