T
- public class AsyncKafkaExporter<T> extends Object implements Exporter<T>
The exporter emit method returns a CompletableFuture object with a boolean that indicates if event has been sent or dropped, caller can either wait on the result and decide what to do based on result, or ignore the result.
Modifier and Type | Class and Description |
---|---|
static class |
AsyncKafkaExporter.Builder<T> |
Modifier and Type | Method and Description |
---|---|
BlockingDeque<io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Tuple<T>> |
buffer() |
void |
close() |
void |
configure(Map<String,?> configs) |
CompletableFuture<Boolean> |
emit(T t)
Filter and transform the events as appropriate and send to the specified destination.
|
static <T> AsyncKafkaExporter.Builder<T> |
newBuilder() |
Object |
producer() |
Set<String> |
reconfigurableConfigs() |
void |
reconfigure(Map<String,?> configs) |
void |
validateReconfiguration(Map<String,?> configs) |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
routeReady
public static <T> AsyncKafkaExporter.Builder<T> newBuilder()
public Set<String> reconfigurableConfigs()
reconfigurableConfigs
in interface org.apache.kafka.common.Reconfigurable
public void validateReconfiguration(Map<String,?> configs) throws org.apache.kafka.common.config.ConfigException
validateReconfiguration
in interface org.apache.kafka.common.Reconfigurable
org.apache.kafka.common.config.ConfigException
public void reconfigure(Map<String,?> configs)
reconfigure
in interface org.apache.kafka.common.Reconfigurable
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public CompletableFuture<Boolean> emit(T t)
Exporter
public BlockingDeque<io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Tuple<T>> buffer()
public void close()
close
in interface AutoCloseable
public Object producer()