...
Terminology
Term | Description |
---|---|
Input Stream Partition Time | The value returned by the TimestampExtractor implementation in use. This can be the record timestamp, wall-clock time or any other notion of time defined by the user. However, as per the API doc, the extracted timestamp MUST represent the milliseconds since midnight, January 1, 1970 UTC. Please note that currently the TimestampExtractor is global to the KafkaStreams instance but after KIP-123 the extractor will be per source allowing multiple different extractors within a topology. |
Stream Time | Defined as the smallest among all its input stream partition timestamps. |
Punctuate Time | This is the reference time used to trigger the Punctuate calls, currently the stream time. |
Punctuate's timestamp argument | Currently the stream time when this method is being called |
Output Record Time | This is the record timestamp for records returned by Transformer.punctuate or generated from punctuate via ProcessorContext.forward. Currently the stream time. |
...