abstract fun resume(topicPartitions: MutableSet<TopicPartition>): KafkaReadStream<K, V>
Resume specified partitions which have been paused with pause.
topicPartitions - topic partition from which resume fetching
Return
current KafkaReadStream instance
abstract fun resume(topicPartitions: MutableSet<TopicPartition>, completionHandler: Handler<AsyncResult<Void>>): KafkaReadStream<K, V>
Resume specified partitions which have been paused with pause.
topicPartitions - topic partition from which resume fetching
completionHandler - handler called on operation completed
Return
current KafkaReadStream instance