vertx / io.vertx.reactivex.kafka.client.producer / KafkaProducer / rxPartitionsFor

rxPartitionsFor

open fun rxPartitionsFor(topic: String): Single<MutableList<PartitionInfo>>

Get the partition metadata for the give topic.

Parameters

topic - topic partition for which getting partitions info

Return