vertx / io.vertx.kafka.client.consumer / KafkaReadStream / partitionsRevokedHandler

partitionsRevokedHandler

abstract fun partitionsRevokedHandler(handler: Handler<MutableSet<TopicPartition>>): KafkaReadStream<K, V>

Set the handler called when topic partitions are revoked to the consumer

Parameters

handler - handler called on revoked topic partitions

Return
current KafkaReadStream instance