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
Typically, the timestamp represents the milliseconds since midnight, January 1, 1970 UTC.
extract
in interface TimestampExtractor
record
- a data record