com.espertech.esperio.kafka

Class EsperIOKafkaInputProcessorContext

java.lang.Object

com.espertech.esperio.kafka.EsperIOKafkaInputProcessorContext

public class EsperIOKafkaInputProcessorContext
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
EsperIOKafkaInputProcessorContext(org.apache.kafka.clients.consumer.KafkaConsumer consumer, com.espertech.esper.core.service.EPServiceProviderSPI engine, java.util.Properties properties, EsperIOKafkaInputAdapter adapter)

Method Summary

Modifier and Type	Method and Description
EsperIOKafkaInputAdapter	getAdapter()
org.apache.kafka.clients.consumer.KafkaConsumer	getConsumer()
com.espertech.esper.core.service.EPServiceProviderSPI	getEngine()
java.util.Properties	getProperties()

Methods inherited from class java.lang.Object

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

Constructor Detail

EsperIOKafkaInputProcessorContext

public EsperIOKafkaInputProcessorContext(org.apache.kafka.clients.consumer.KafkaConsumer consumer,
                                         com.espertech.esper.core.service.EPServiceProviderSPI engine,
                                         java.util.Properties properties,
                                         EsperIOKafkaInputAdapter adapter)

Method Detail

getConsumer

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

getEngine

public com.espertech.esper.core.service.EPServiceProviderSPI getEngine()

getProperties

public java.util.Properties getProperties()

getAdapter

public EsperIOKafkaInputAdapter getAdapter()