public static class AsyncKafkaExporter.Builder<T> extends Object
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) |
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()