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

position

open fun position(partition: TopicPartition, handler: Handler<AsyncResult<Long>>): Unit

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

handler - handler called on operation completed