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.
Due to internal buffering of messages, the record handler will continue to observe messages from the given topicParations until some time after the given completionHandler is called. In contrast, the once the given completionHandler is called the #batchHandler(Handler) will not see messages from the given topicParations.
topicPartitions - topic partition from which suspend fetching
completionHandler - handler called on operation completed
Return
current KafkaReadStream instance