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

partitionsAssignedHandler

open fun partitionsAssignedHandler(handler: Handler<MutableSet<TopicPartition>>): KafkaConsumer<K, V>

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

Parameters

handler - handler called on assigned topic partitions

Return
current KafkaConsumer instance