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

rxAssignment

open fun rxAssignment(): Single<MutableSet<TopicPartition>>

Get the set of partitions currently assigned to this consumer.

Return