public static final class EventAsyncKafkaExporter.Builder extends Object
Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
EventAsyncKafkaExporter |
build() |
EventAsyncKafkaExporter.Builder |
withBufferSize(int bufferSize) |
EventAsyncKafkaExporter.Builder |
withDataSerializer(Function<io.confluent.telemetry.api.events.Event,org.apache.kafka.clients.producer.ProducerRecord<String,byte[]>> dataSerializer) |
EventAsyncKafkaExporter.Builder |
withProducerProperties(Properties producerProperties) |
EventAsyncKafkaExporter.Builder |
withTopicSupplier(TopicSupplier<io.confluent.telemetry.api.events.Event> topicSupplier) |
public EventAsyncKafkaExporter.Builder withBufferSize(int bufferSize)
public EventAsyncKafkaExporter.Builder withProducerProperties(Properties producerProperties)
public EventAsyncKafkaExporter.Builder withTopicSupplier(TopicSupplier<io.confluent.telemetry.api.events.Event> topicSupplier)
public EventAsyncKafkaExporter.Builder withDataSerializer(Function<io.confluent.telemetry.api.events.Event,org.apache.kafka.clients.producer.ProducerRecord<String,byte[]>> dataSerializer)
public EventAsyncKafkaExporter build()