vertx / io.vertx.reactivex.kafka.client.consumer / KafkaConsumer / rxPaused

rxPaused

open fun rxPaused(): Single<MutableSet<TopicPartition>>

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

Return