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