vertx / io.vertx.kafka.client.consumer / KafkaReadStream / commit

commit

abstract fun commit(): Unit

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

abstract fun commit(completionHandler: Handler<AsyncResult<MutableMap<TopicPartition, OffsetAndMetadata>>>): Unit

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

Parameters

completionHandler - handler called on operation completed

abstract fun commit(offsets: MutableMap<TopicPartition, OffsetAndMetadata>): Unit

Commit the specified offsets for the specified list of topics and partitions to Kafka.

Parameters

offsets - offsets list to commit

abstract fun commit(offsets: MutableMap<TopicPartition, OffsetAndMetadata>, completionHandler: Handler<AsyncResult<MutableMap<TopicPartition, OffsetAndMetadata>>>): Unit

Commit the specified offsets for the specified list of topics and partitions to Kafka.

Parameters

offsets - offsets list to commit

completionHandler - handler called on operation completed