open fun resume(): KafkaConsumer<K, V>
Overrides ReadStream.resume
open fun resume(topicPartition: TopicPartition): KafkaConsumer<K, V>
Resume specified partition which have been paused with pause.
topicPartition - topic partition from which resume fetching
Return
current KafkaConsumer instance
open fun resume(topicPartitions: MutableSet<TopicPartition>): KafkaConsumer<K, V>
Resume specified partitions which have been paused with pause.
topicPartitions - topic partition from which resume fetching
Return
current KafkaConsumer instance
open fun resume(topicPartition: TopicPartition, completionHandler: Handler<AsyncResult<Void>>): KafkaConsumer<K, V>
Resume specified partition which have been paused with pause.
topicPartition - topic partition from which resume fetching
completionHandler - handler called on operation completed
Return
current KafkaConsumer instance
open fun resume(topicPartitions: MutableSet<TopicPartition>, completionHandler: Handler<AsyncResult<Void>>): KafkaConsumer<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 KafkaConsumer instance