abstract fun commit(): Unit
Commit current offsets for all the subscribed list of topics and partition.
abstract fun commit(completionHandler: Handler<AsyncResult<Void>>): Unit
Commit current offsets for all the subscribed list of topics and partition.
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.
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.