open fun seekToBeginning(topicPartition: TopicPartition): KafkaConsumer<K, V>
Seek to the first offset for each of the given partition.
topicPartition - topic partition for which seek
Return
current KafkaConsumer instance
open fun seekToBeginning(topicPartitions: MutableSet<TopicPartition>): KafkaConsumer<K, V>
Seek to the first offset for each of the given partitions.
topicPartitions - topic partition for which seek
Return
current KafkaConsumer instance
open fun seekToBeginning(topicPartition: TopicPartition, completionHandler: Handler<AsyncResult<Void>>): KafkaConsumer<K, V>
Seek to the first offset for each of the given partition.
topicPartition - topic partition for which seek
completionHandler - handler called on operation completed
Return
current KafkaConsumer instance
open fun seekToBeginning(topicPartitions: MutableSet<TopicPartition>, completionHandler: Handler<AsyncResult<Void>>): KafkaConsumer<K, V>
Seek to the first offset for each of the given partitions.
topicPartitions - topic partition for which seek
completionHandler - handler called on operation completed
Return
current KafkaConsumer instance