open fun rxPosition(partition: TopicPartition): Single<Long>
Get the offset of the next record that will be fetched (if a record with that offset exists).
partition - The partition to get the position for
partition
Return