public interface Exporter<T> extends org.apache.kafka.common.Reconfigurable, AutoCloseable
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Boolean> |
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.
|
reconfigurableConfigs, reconfigure, validateReconfiguration
close
CompletableFuture<Boolean> emit(T event)
default boolean routeReady(T event)