Package com.espertech.esperio.kafka

Class EsperIOKafkaOutputFlowControllerByAnnotatedStmt.KafkaOutputDefaultListener

java.lang.Object

com.espertech.esperio.kafka.EsperIOKafkaOutputFlowControllerByAnnotatedStmt.KafkaOutputDefaultListener

All Implemented Interfaces:

com.espertech.esper.runtime.client.UpdateListener

Enclosing class:

EsperIOKafkaOutputFlowControllerByAnnotatedStmt

public static class EsperIOKafkaOutputFlowControllerByAnnotatedStmt.KafkaOutputDefaultListener
extends Object
implements com.espertech.esper.runtime.client.UpdateListener

Constructor Summary

Constructors

Constructor	Description
KafkaOutputDefaultListener(com.espertech.esper.runtime.client.EPRuntime runtime, com.espertech.esper.runtime.client.EPStatement statement, org.apache.kafka.clients.producer.KafkaProducer producer, Set<String> topics)

Method Summary

Modifier and Type	Method	Description
void	update(com.espertech.esper.common.client.EventBean[] newEvents, com.espertech.esper.common.client.EventBean[] oldEvents, com.espertech.esper.runtime.client.EPStatement statement, com.espertech.esper.runtime.client.EPRuntime runtime)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaOutputDefaultListener

public KafkaOutputDefaultListener(com.espertech.esper.runtime.client.EPRuntime runtime,
 com.espertech.esper.runtime.client.EPStatement statement,
 org.apache.kafka.clients.producer.KafkaProducer producer,
 Set<String> topics)

Method Details

update

public void update(com.espertech.esper.common.client.EventBean[] newEvents,
 com.espertech.esper.common.client.EventBean[] oldEvents,
 com.espertech.esper.runtime.client.EPStatement statement,
 com.espertech.esper.runtime.client.EPRuntime runtime)

Specified by:

update in interface com.espertech.esper.runtime.client.UpdateListener