vertx / io.vertx.kotlin.kafka.client.consumer / io.vertx.kafka.client.consumer.KafkaConsumer / positionAwait
positionAwait
suspend fun <K, V> KafkaConsumer<K, V>.positionAwait(partition: TopicPartition): 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
handler - handler called on operation completed