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

rxSeekToEnd

open fun rxSeekToEnd(topicPartition: TopicPartition): Completable

Seek to the last offset for each of the given partition.

Parameters

topicPartition - topic partition for which seek

Return

open fun rxSeekToEnd(topicPartitions: MutableSet<TopicPartition>): Completable

Seek to the last offset for each of the given partitions.

Parameters

topicPartitions - topic partition for which seek

Return