suspend fun AdminUtils.createTopicAwait(topicName: String, partitionCount: Int, replicationFactor: Int): Unit
Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s)
topicName
- Name of the to-be-created topic
partitionCount
- Number of partitions
replicationFactor
- Number of replicates. Must be lower or equal to the number of available Brokers
completionHandler
- vert.x callback
suspend fun AdminUtils.createTopicAwait(topicName: String, partitionCount: Int, replicationFactor: Int, topicConfig: Map<String, String>): Unit
Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s). In contrast to @see io.vertx.kafka.admin.AdminUtils, one can pass in additional configuration parameters as a map (String -> String).
topicName
- Name of the to-be-created topic
partitionCount
- Number of partitions
replicationFactor
- Number of replicates. Must be lower or equal to the number of available Brokers
topicConfig
- map with additional topic configuration parameters