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

rxSeekToBeginning

open fun rxSeekToBeginning(topicPartition: TopicPartition): Single<Void>

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

Parameters

topicPartition - topic partition for which seek

Return

open fun rxSeekToBeginning(topicPartitions: MutableSet<TopicPartition>): Single<Void>

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

Parameters

topicPartitions - topic partition for which seek

Return