abstract 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
abstract 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
abstract fun seekToBeginning(topicPartition: TopicPartition, completionHandler: Handler<AsyncResult<Void>>): KafkaConsumer<K, V>
Seek to the first offset for each of the given partition.
Due to internal buffering of messages, the record handler 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 #batchHandler(Handler) will only see messages consistent with the new offset.
topicPartition - topic partition for which seek
completionHandler - handler called on operation completed
Return
current KafkaConsumer instance
abstract fun seekToBeginning(topicPartitions: MutableSet<TopicPartition>, completionHandler: Handler<AsyncResult<Void>>): KafkaConsumer<K, V>
Seek to the first offset for each of the given partitions.
Due to internal buffering of messages, the record handler 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 #batchHandler(Handler) will only see messages consistent with the new offset.
topicPartitions - topic partition for which seek
completionHandler - handler called on operation completed
Return
current KafkaConsumer instance