io.confluent.telemetry.events.exporter.kafka

Class EventAsyncKafkaExporter

java.lang.Object

io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter<io.confluent.telemetry.api.events.Event>

io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter

All Implemented Interfaces:

Exporter<io.confluent.telemetry.api.events.Event>, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.common.Reconfigurable

public class EventAsyncKafkaExporter
extends AsyncKafkaExporter<io.confluent.telemetry.api.events.Event>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EventAsyncKafkaExporter.Builder

Field Summary

Fields

Modifier and Type	Field and Description
static io.cloudevents.core.format.EventFormat	format

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	EventAsyncKafkaExporter(EventAsyncKafkaExporter.Builder builder)

Method Summary

Modifier and Type	Method and Description
static EventAsyncKafkaExporter.Builder	newBuilder(Map<String,Object> config)

Methods inherited from class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter

buffer, close, configure, emit, newBuilder, producer, reconfigurableConfigs, reconfigure, validateReconfiguration

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.confluent.telemetry.events.exporter.Exporter

routeReady

Field Detail

format

public static io.cloudevents.core.format.EventFormat format

Constructor Detail

EventAsyncKafkaExporter

protected EventAsyncKafkaExporter(EventAsyncKafkaExporter.Builder builder)

Method Detail

newBuilder

public static EventAsyncKafkaExporter.Builder newBuilder(Map<String,Object> config)