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

# rxSeek

`open fun rxSeek(topicPartition: TopicPartition, offset: Long): Single<Void>`

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

Due to internal buffering of messages, the will continue to observe messages fetched with respect to the old offset until some time after the given `completionHandler` is called. In contrast, the once the given `completionHandler` is called the `io.vertx.rxjava.kafka.client.consumer.KafkaConsumer#batchHandler` will only see messages consistent with the new offset.

### Parameters

`topicPartition` - topic partition for which seek

`offset` - offset to seek inside the topic partition

Return