com.espertech.esperio.kafka

Class EsperIOKafkaOutputFlowControllerByAnnotatedStmt.KafkaOutputDefaultListener

java.lang.Object

com.espertech.esperio.kafka.EsperIOKafkaOutputFlowControllerByAnnotatedStmt.KafkaOutputDefaultListener

All Implemented Interfaces:

com.espertech.esper.client.UpdateListener

Enclosing class:

EsperIOKafkaOutputFlowControllerByAnnotatedStmt

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

Constructor Summary

Constructors

Constructor and Description
KafkaOutputDefaultListener(com.espertech.esper.client.EPServiceProvider engine, com.espertech.esper.client.EPStatement statement, org.apache.kafka.clients.producer.KafkaProducer producer, java.util.Set<java.lang.String> topics)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaOutputDefaultListener

public KafkaOutputDefaultListener(com.espertech.esper.client.EPServiceProvider engine,
                                  com.espertech.esper.client.EPStatement statement,
                                  org.apache.kafka.clients.producer.KafkaProducer producer,
                                  java.util.Set<java.lang.String> topics)

Method Detail

update

public void update(com.espertech.esper.client.EventBean[] newEvents,
                   com.espertech.esper.client.EventBean[] oldEvents)

Specified by:

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