org.apache.kafka.streams.processor

Class WallclockTimestampExtractor

java.lang.Object

org.apache.kafka.streams.processor.WallclockTimestampExtractor

All Implemented Interfaces:

TimestampExtractor

@InterfaceStability.Evolving
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, UsePreviousTimeOnInvalidTimestamp

Constructor Summary

Constructors

Constructor and Description
WallclockTimestampExtractor()

Method Summary

Modifier and Type	Method and Description
long	extract(ConsumerRecord<Object,Object> record, long previousTimestamp) Return the current wall clock time as timestamp.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WallclockTimestampExtractor

public WallclockTimestampExtractor()

Method Detail

extract

public long extract(ConsumerRecord<Object,Object> record,
                    long previousTimestamp)

Return the current wall clock time as timestamp.

Specified by:

extract in interface TimestampExtractor

Parameters:

record - a data record

previousTimestamp - the latest 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