abstract fun pause(topicPartitions: MutableSet<TopicPartition>): KafkaReadStream<K, V>
Suspend fetching from the requested partitions.
topicPartitions - topic partition from which suspend fetching
Return
current KafkaReadStream instance
abstract fun pause(topicPartitions: MutableSet<TopicPartition>, completionHandler: Handler<AsyncResult<Void>>): KafkaReadStream<K, V>
Suspend fetching from the requested partitions.
topicPartitions - topic partition from which suspend fetching
completionHandler - handler called on operation completed
Return
current KafkaReadStream instance