Package com.espertech.esperio.kafka

Interface EsperIOKafkaInputProcessor

All Known Implementing Classes:

EsperIOKafkaInputProcessorDefault, EsperIOKafkaInputProcessorJson

public interface EsperIOKafkaInputProcessor

Method Summary

Modifier and Type	Method	Description
void	close()
void	init(EsperIOKafkaInputProcessorContext context)
void	process(org.apache.kafka.clients.consumer.ConsumerRecords<Object,Object> records)

Method Details

init

void init(EsperIOKafkaInputProcessorContext context)

process

void process(org.apache.kafka.clients.consumer.ConsumerRecords<Object,Object> records)

close

void close()