vertx / io.vertx.rxjava.kafka.client.producer / KafkaProducer / close

close

open fun close(): Unit

Close the producer

open fun close(completionHandler: Handler<AsyncResult<Void>>): Unit

Close the producer

Parameters

completionHandler - handler called on operation completed

open fun close(timeout: Long, completionHandler: Handler<AsyncResult<Void>>): Unit

Close the producer

Parameters

timeout - timeout to wait for closing

completionHandler - handler called on operation completed