vertx / io.vertx.reactivex.kafka.client.consumer / KafkaConsumer / rxPosition

rxPosition

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).

Parameters

partition - The partition to get the position for

Return