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

rxResume

open fun rxResume(topicPartition: TopicPartition): Completable

Resume specified partition which have been paused with pause.

Parameters

topicPartition - topic partition from which resume fetching

Return

open fun rxResume(topicPartitions: MutableSet<TopicPartition>): Completable

Resume specified partitions which have been paused with pause.

Parameters

topicPartitions - topic partition from which resume fetching

Return