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