WallclockTimestampExtractor

WallclockTimestampExtractor is a TimestampExtractor that uses the current wall clock time as timestamp when requested to extract a timestamp from a record.

extract Method

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.

results matching ""

    No results matching ""