abstract fun seekToBeginning(topicPartitions: MutableSet<TopicPartition>): KafkaReadStream<K, V>
Seek to the first offset for each of the given partitions.
topicPartitions - topic partition for which seek
Return
current KafkaReadStream instance
abstract fun seekToBeginning(topicPartitions: MutableSet<TopicPartition>, completionHandler: Handler<AsyncResult<Void>>): KafkaReadStream<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 KafkaReadStream instance