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