suspend fun <K, V> KafkaConsumer<K, V>.commitAwait(): Unit
Commit current offsets for all the subscribed list of topics and partition.