com.espertech.esperio.kafka

Interface EsperIOKafkaInputTimestampExtractor

All Known Implementing Classes:

EsperIOKafkaInputTimestampExtractorConsumerRecord

public interface EsperIOKafkaInputTimestampExtractor

Method Summary

Modifier and Type	Method and Description
long	extract(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object,java.lang.Object> record)

Method Detail

extract

long extract(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object,java.lang.Object> record)