open fun rxResume(topicPartition: TopicPartition): Completable
Resume specified partition which have been paused with pause.
topicPartition - topic partition from which resume fetching
Return
open fun rxResume(topicPartitions: MutableSet<TopicPartition>): Completable
Resume specified partitions which have been paused with pause.
topicPartitions - topic partition from which resume fetching
Return