public static class AsyncKafkaExporter.Builder<T> extends Object
Modifier and Type | Field and Description |
---|---|
protected int |
bufferSize |
protected Function<T,org.apache.kafka.clients.producer.ProducerRecord<String,byte[]>> |
dataSerializer |
protected org.apache.kafka.clients.producer.Producer<String,byte[]> |
kafkaProducer |
protected Properties |
producerProperties |
protected TopicSupplier<T> |
topicSupplier |
Modifier | Constructor and Description |
---|---|
protected |
Builder() |
Modifier and Type | Method and 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> |
withProducerProperties(Properties producerProperties) |
AsyncKafkaExporter.Builder<T> |
withTopicSupplier(TopicSupplier<T> topicSupplier) |
protected Properties producerProperties
protected int bufferSize
protected TopicSupplier<T> topicSupplier
protected org.apache.kafka.clients.producer.Producer<String,byte[]> kafkaProducer
public AsyncKafkaExporter.Builder<T> withProducerProperties(Properties producerProperties)
public AsyncKafkaExporter.Builder<T> withBufferSize(int bufferSize)
public AsyncKafkaExporter.Builder<T> withTopicSupplier(TopicSupplier<T> topicSupplier)
public AsyncKafkaExporter.Builder<T> withDataSerializer(Function<T,org.apache.kafka.clients.producer.ProducerRecord<String,byte[]>> dataSerializer)
public AsyncKafkaExporter<T> build()