Class WallclockTimestampExtractor

java.lang.Object
org.apache.kafka.streams.processor.WallclockTimestampExtractor
All Implemented Interfaces:
TimestampExtractor

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:
FailOnInvalidTimestamp, LogAndSkipOnInvalidTimestamp, UsePartitionTimeOnInvalidTimestamp
  • 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
      Parameters:
      record - a data record
      partitionTime - the highest extracted valid timestamp of the current record's partition˙ (could be -1 if unknown)
      Returns:
      the current wall clock time, expressed in milliseconds since midnight, January 1, 1970 UTC