vertx / io.vertx.rxjava.kafka.client.consumer / KafkaConsumer / rxPause

rxPause

open fun rxPause(topicPartition: TopicPartition): Single<Void>

Suspend fetching from the requested partition.

Parameters

topicPartition - topic partition from which suspend fetching

Return

open fun rxPause(topicPartitions: MutableSet<TopicPartition>): Single<Void>

Suspend fetching from the requested partitions.

Parameters

topicPartitions - topic partition from which suspend fetching

Return