public class EventAsyncKafkaExporter extends AsyncKafkaExporter<io.confluent.telemetry.api.events.Event>
Modifier and Type | Class and Description |
---|---|
static class |
EventAsyncKafkaExporter.Builder |
Modifier and Type | Field and Description |
---|---|
static io.cloudevents.core.format.EventFormat |
format |
Modifier and Type | Method and Description |
---|---|
static EventAsyncKafkaExporter.Builder |
newBuilder(Map<String,Object> config) |
buffer, close, configure, emit, newBuilder, producer, reconfigurableConfigs, reconfigure, validateReconfiguration
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
routeReady
public static EventAsyncKafkaExporter.Builder newBuilder(Map<String,Object> config)