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