com.espertech.esperio.kafka

Interface EsperIOKafkaInputProcessor

All Known Implementing Classes:

EsperIOKafkaInputProcessorDefault

public interface EsperIOKafkaInputProcessor

Method Summary

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

Method Detail

init

void init(EsperIOKafkaInputProcessorContext context)

process

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

close

void close()