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 | Constructor and Description |
---|---|
protected |
EventAsyncKafkaExporter(EventAsyncKafkaExporter.Builder builder) |
Modifier and Type | Method and Description |
---|---|
static EventAsyncKafkaExporter.Builder |
newBuilder(Map<String,Object> config) |
buffer, close, configure, emit, newBuilder, producer, reconfigurableConfigs, reconfigure, validateReconfiguration
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
routeReady
protected EventAsyncKafkaExporter(EventAsyncKafkaExporter.Builder builder)
public static EventAsyncKafkaExporter.Builder newBuilder(Map<String,Object> config)