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

partitionsAssignedHandler

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

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

Parameters

handler - handler called on assigned topic partitions

Return
current KafkaReadStream instance