vertx / io.vertx.rxjava.kafka.client.consumer / KafkaConsumer / paused

paused

open fun paused(handler: Handler<AsyncResult<MutableSet<TopicPartition>>>): Unit

Get the set of partitions that were previously paused by a call to pause(Set).

Parameters

handler - handler called on operation completed