vertx / io.vertx.kotlin.kafka.client.consumer / io.vertx.kafka.client.consumer.KafkaConsumer / pausedAwait
pausedAwait
suspend fun <K, V> KafkaConsumer<K, V>.pausedAwait(): Set<TopicPartition>
Get the set of partitions that were previously paused by a call to pause(Set).
Parameters
handler - handler called on operation completed