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