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

rxSeek

open fun rxSeek(topicPartition: TopicPartition, offset: Long): Completable

Overrides the fetch offsets that the consumer will use on the next poll.

Parameters

topicPartition - topic partition for which seek

offset - offset to seek inside the topic partition

Return