Companion

Properties

The topic config an acks=all write waits for that many replicas by.

fun create(options: KafkaOptions, replicationFactor: Short? = null, configs: Map<String, String> = emptyMap()): KafkaTopicAdmin

An admin of options' bootstrap servers and properties, creating topics with replicationFactor and configs.