public class WallclockTimestampExtractor extends Object implements TimestampExtractor
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).
| Constructor and Description |
|---|
WallclockTimestampExtractor() |
| Modifier and Type | Method and Description |
|---|---|
long | extract(org.apache.kafka.clients.consumer.ConsumerRecord<Object,Object> record, long partitionTime)Return the current wall clock time as timestamp. |
public long extract(org.apache.kafka.clients.consumer.ConsumerRecord<Object,Object> record, long partitionTime)
extract in interface TimestampExtractorrecord - a data recordpartitionTime - the highest extracted valid timestamp of the current record's partition˙ (could be -1 if unknown)