create

open suspend override fun create(topics: Map<String, Int>)


fun create(topic: String, partitions: Int = this.partitions)

Creates topic with partitions partitions, unless it exists.