Class WallclockTimestampExtractor

All Implemented Interfaces:

public class WallclockTimestampExtractor extends Object implements TimestampExtractor
Retrieves current wall clock timestamps as System.currentTimeMillis().

Using this extractor effectively provides processing-time semantics.

If you need event-time semantics, use FailOnInvalidTimestamp with built-in CreateTime or LogAppendTime timestamp (see KIP-32: Add timestamps to Kafka message for details).

See Also:
  • Constructor Details

    • WallclockTimestampExtractor

      public WallclockTimestampExtractor()
  • Method Details

    • extract

      public long extract(ConsumerRecord<Object,Object> record, long partitionTime)
      Return the current wall clock time as timestamp.
      Specified by:
      extract in interface TimestampExtractor
      record - a data record
      partitionTime - the highest extracted valid timestamp of the current record's partition˙ (could be -1 if unknown)
      the current wall clock time, expressed in milliseconds since midnight, January 1, 1970 UTC