org.apache.kafka.streams.processor

Interface TimestampExtractor

All Known Implementing Classes:

ConsumerRecordTimestampExtractor, WallclockTimestampExtractor

public interface TimestampExtractor

An interface that allows the Kafka Streams framework to extract a timestamp from an instance of ConsumerRecord. The extracted timestamp is defined as milliseconds.

Method Summary

Methods

Modifier and Type	Method and Description
long	extract(ConsumerRecord<Object,Object> record) Extracts a timestamp from a record.

Method Detail

extract

long extract(ConsumerRecord<Object,Object> record)

Extracts a timestamp from a record.

The extracted timestamp MUST represent the milliseconds since midnight, January 1, 1970 UTC. It is important to note that this timestamp may become the message timestamp for any messages sent to changelogs updated by KTables and joins. The message timestamp is used for log retention and log rolling, so using nonsensical values may result in excessive log rolling and therefore broker performance degradation.

Parameters:

record - a data record

Returns:

the timestamp of the record