public class EsperIOKafkaInputSubscriberContext extends Object
Constructor and Description |
---|
EsperIOKafkaInputSubscriberContext(org.apache.kafka.clients.consumer.KafkaConsumer consumer,
com.espertech.esper.client.EPServiceProvider engine,
Properties properties) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.consumer.KafkaConsumer |
getConsumer() |
com.espertech.esper.client.EPServiceProvider |
getEngine() |
Properties |
getProperties() |
public EsperIOKafkaInputSubscriberContext(org.apache.kafka.clients.consumer.KafkaConsumer consumer, com.espertech.esper.client.EPServiceProvider engine, Properties properties)
public org.apache.kafka.clients.consumer.KafkaConsumer getConsumer()
public com.espertech.esper.client.EPServiceProvider getEngine()
public Properties getProperties()