public interface Exporter
extends org.apache.kafka.common.Reconfigurable, java.lang.AutoCloseable
Modifier and Type | Method and Description |
---|---|
void |
append(io.cloudevents.CloudEvent event)
Filter and transform the events as appropriate and send to the specified destination
|
boolean |
routeReady(io.cloudevents.CloudEvent event)
Checks if a topic is ready.
|
void append(io.cloudevents.CloudEvent event) throws java.lang.RuntimeException
java.lang.RuntimeException
boolean routeReady(io.cloudevents.CloudEvent event)