public class ConsumerRecordTimestampExtractor extends java.lang.Object implements TimestampExtractor
WallclockTimestampExtractor
.Constructor and Description |
---|
ConsumerRecordTimestampExtractor() |
Modifier and Type | Method and Description |
---|---|
long |
extract(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object,java.lang.Object> record)
Extracts a timestamp from a record.
|
public long extract(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object,java.lang.Object> record)
TimestampExtractor
The extracted timestamp MUST represent the milliseconds since midnight, January 1, 1970 UTC.
It is important to note that this timestamp may become the message timestamp for any messages sent to changelogs updated by KTable
s
and joins. The message timestamp is used for log retention and log rolling, so using nonsensical values may result in
excessive log rolling and therefore broker performance degradation.
extract
in interface TimestampExtractor
record
- a data record