open fun rxPause(topicPartition: TopicPartition): Completable
Suspend fetching from the requested partition.
topicPartition - topic partition from which suspend fetching
Return
open fun rxPause(topicPartitions: MutableSet<TopicPartition>): Completable
Suspend fetching from the requested partitions.
topicPartitions - topic partition from which suspend fetching
Return