public interface TimestampExtractor
ConsumerRecord
.
The extracted timestamp is defined as milliseconds.Modifier and Type | Method and Description |
---|---|
long |
extract(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object,java.lang.Object> record)
Extracts a timestamp from a message
|