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

rxCommit

open fun rxCommit(): Single<Void>

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

Return