EsperIOKafkaInputTimestampExtractorConsumerRecord (EsperIO API Documentation)

java.lang.Object

com.espertech.esperio.kafka.EsperIOKafkaInputTimestampExtractorConsumerRecord

All Implemented Interfaces:: EsperIOKafkaInputTimestampExtractor

public class EsperIOKafkaInputTimestampExtractorConsumerRecord extends Object implements EsperIOKafkaInputTimestampExtractor

Constructor Summary

Constructors

Constructor

Description

EsperIOKafkaInputTimestampExtractorConsumerRecord()
Method Summary

Modifier and Type

Method

Description

long

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

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- EsperIOKafkaInputTimestampExtractorConsumerRecord
  
  public EsperIOKafkaInputTimestampExtractorConsumerRecord()
Method Details
- extract
  
  public long extract(org.apache.kafka.clients.consumer.ConsumerRecord<Object,Object> record)
  
  Specified by:
  
  extract in interface EsperIOKafkaInputTimestampExtractor