Package com.espertech.esperio.kafka

Class EsperIOKafkaInputProcessorContext

java.lang.Object

com.espertech.esperio.kafka.EsperIOKafkaInputProcessorContext

public class EsperIOKafkaInputProcessorContext
extends Object

Constructor Summary

Constructors

Constructor	Description
EsperIOKafkaInputProcessorContext(org.apache.kafka.clients.consumer.KafkaConsumer consumer, com.espertech.esper.runtime.internal.kernel.service.EPRuntimeSPI runtime, Properties properties, EsperIOKafkaInputAdapter adapter)

Method Summary

Modifier and Type	Method	Description
EsperIOKafkaInputAdapter	getAdapter()
org.apache.kafka.clients.consumer.KafkaConsumer	getConsumer()
Properties	getProperties()
com.espertech.esper.runtime.internal.kernel.service.EPRuntimeSPI	getRuntime()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

EsperIOKafkaInputProcessorContext

public EsperIOKafkaInputProcessorContext(org.apache.kafka.clients.consumer.KafkaConsumer consumer,
 com.espertech.esper.runtime.internal.kernel.service.EPRuntimeSPI runtime,
 Properties properties,
 EsperIOKafkaInputAdapter adapter)

Method Details

getConsumer

public org.apache.kafka.clients.consumer.KafkaConsumer getConsumer()

getRuntime

public com.espertech.esper.runtime.internal.kernel.service.EPRuntimeSPI getRuntime()

getProperties

public Properties getProperties()

getAdapter

public EsperIOKafkaInputAdapter getAdapter()