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 TimestampExtractor
record
- a data recordpartitionTime
- the highest extracted valid timestamp of the current record's partition˙ (could be -1 if unknown)