WallclockTimestampExtractor is a TimestampExtractor that uses the current wall clock time as timestamp when requested to extract a timestamp from a record.
long extract(final ConsumerRecord<Object, Object> record, final long previousTimestamp)|
Note
|
extract is part of TimestampExtractor Contract to extract a timestamp from a record.
|
extract simply requests the Java System for the current time in milliseconds.