vertx / io.vertx.rxjava.kafka.client.consumer / KafkaConsumer / commit

commit

open fun commit(): Unit

Commit current offsets for all the subscribed list of topics and partition.

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

Commit current offsets for all the subscribed list of topics and partition.

Parameters

completionHandler - handler called on operation completed