suspend fun <K, V> KafkaConsumer<K, V>.seekToEndAwait(topicPartition: TopicPartition): Unit
Seek to the last offset for each of the given partition.
topicPartition - topic partition for which seek
completionHandler - handler called on operation completed
Returncurrent
KafkaConsumer instance *
suspend fun <K, V> KafkaConsumer<K, V>.seekToEndAwait(topicPartitions: Set<TopicPartition>): Unit
Seek to the last offset for each of the given partitions.
topicPartitions - topic partition for which seek
completionHandler - handler called on operation completed
Returncurrent
KafkaConsumer instance *