public class EsperIOKafkaInputTimestampExtractorConsumerRecord extends java.lang.Object implements EsperIOKafkaInputTimestampExtractor
Constructor and Description |
---|
EsperIOKafkaInputTimestampExtractorConsumerRecord() |
Modifier and Type | Method and Description |
---|---|
long |
extract(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object,java.lang.Object> record) |
public EsperIOKafkaInputTimestampExtractorConsumerRecord()
public long extract(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object,java.lang.Object> record)
extract
in interface EsperIOKafkaInputTimestampExtractor