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

Class EventAsyncKafkaExporter.Builder

java.lang.Object

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

Enclosing class:

EventAsyncKafkaExporter

public static final class EventAsyncKafkaExporter.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	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	withFilter(Predicate<io.confluent.telemetry.api.events.Event> filter)
EventAsyncKafkaExporter.Builder	withProducerProperties(Properties producerProperties)
EventAsyncKafkaExporter.Builder	withTopicSupplier(TopicSupplier<io.confluent.telemetry.api.events.Event> topicSupplier)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

withBufferSize

public EventAsyncKafkaExporter.Builder withBufferSize(int bufferSize)

withProducerProperties

public EventAsyncKafkaExporter.Builder withProducerProperties(Properties producerProperties)

withTopicSupplier

public EventAsyncKafkaExporter.Builder withTopicSupplier(TopicSupplier<io.confluent.telemetry.api.events.Event> topicSupplier)

withDataSerializer

public EventAsyncKafkaExporter.Builder withDataSerializer(Function<io.confluent.telemetry.api.events.Event,org.apache.kafka.clients.producer.ProducerRecord<String,byte[]>> dataSerializer)

withFilter

public EventAsyncKafkaExporter.Builder withFilter(Predicate<io.confluent.telemetry.api.events.Event> filter)

build

public EventAsyncKafkaExporter build()