vertx / io.vertx.reactivex.kafka.client.producer / KafkaProducer / flush

flush

open fun flush(completionHandler: Handler<Void>): KafkaProducer<K, V>

Invoking this method makes all buffered records immediately available to write

Parameters

completionHandler - handler called on operation completed

Return
current KafkaProducer instance