open fun rxSeekToBeginning(topicPartition: TopicPartition): Completable
Seek to the first offset for each of the given partition.
topicPartition - topic partition for which seek
Return
open fun rxSeekToBeginning(topicPartitions: MutableSet<TopicPartition>): Completable
Seek to the first offset for each of the given partitions.
topicPartitions - topic partition for which seek
Return