Package io.confluent.telemetry.events.exporter.kafka.async

Class AsyncKafkaExporter.Builder<T>

java.lang.Object

io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder<T>

Enclosing class:

AsyncKafkaExporter<T>

public static class AsyncKafkaExporter.Builder<T>
extends Object

Method Summary

Modifier and Type	Method	Description
AsyncKafkaExporter<T>	build()
AsyncKafkaExporter.Builder<T>	withBufferSize(int bufferSize)
AsyncKafkaExporter.Builder<T>	withDataSerializer(Function<T,org.apache.kafka.clients.producer.ProducerRecord<String,byte[]>> dataSerializer)
AsyncKafkaExporter.Builder<T>	withFilter(Predicate<T> filter)
AsyncKafkaExporter.Builder<T>	withProducerProperties(Properties producerProperties)
AsyncKafkaExporter.Builder<T>	withTopicSupplier(TopicSupplier<T> topicSupplier)

Methods inherited from class java.lang.Object

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

Method Details

withProducerProperties

public AsyncKafkaExporter.Builder<T> withProducerProperties(Properties producerProperties)

withBufferSize

public AsyncKafkaExporter.Builder<T> withBufferSize(int bufferSize)

withTopicSupplier

public AsyncKafkaExporter.Builder<T> withTopicSupplier(TopicSupplier<T> topicSupplier)

withDataSerializer

public AsyncKafkaExporter.Builder<T> withDataSerializer(Function<T,org.apache.kafka.clients.producer.ProducerRecord<String,byte[]>> dataSerializer)

withFilter

public AsyncKafkaExporter.Builder<T> withFilter(Predicate<T> filter)

build

public AsyncKafkaExporter<T> build()