public class UsePreviousTimeOnInvalidTimestamp extends Object
Here, "embedded metadata" refers to the fact that compatible Kafka producer clients automatically and transparently embed such timestamps into message metadata they send to Kafka, which can then be retrieved via this timestamp extractor.
If the embedded metadata timestamp represents CreateTime (cf. Kafka broker setting
message.timestamp.type and Kafka topic setting
this extractor effectively provides event-time semantics.
If LogAppendTime is used as broker/topic setting to define the embedded metadata timestamps,
using this extractor effectively provides ingestion-time semantics.
If you need processing-time semantics, use
|Constructor and Description|
|Modifier and Type||Method and Description|
Extracts the embedded metadata timestamp from the given
Returns the current stream-time as new timestamp for the record.
public long onInvalidTimestamp(ConsumerRecord<Object,Object> record, long recordTimestamp, long previousTimestamp) throws StreamsException
record- a data record
recordTimestamp- the timestamp extractor from the record
previousTimestamp- the latest extracted valid timestamp of the current record's partition˙ (could be -1 if unknown)
StreamsException- if latest extracted valid timestamp is unknown
public long extract(ConsumerRecord<Object,Object> record, long previousTimestamp)