Package 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	Description
static final class	EventAsyncKafkaExporter.Builder

Field Summary

Fields

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

Method Summary

Modifier and Type	Method	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

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

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

routeReady

Field Details

format

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

Method Details

newBuilder

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