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