KafkaTopicAdmin

constructor(admin: Admin, replicationFactor: Short?, configs: Map<String, String>, visibleWithin: Duration, dispatcher: CoroutineDispatcher, closeTimeout: Duration)
constructor(admin: Admin, replicationFactor: Short? = null, configs: Map<String, String> = emptyMap(), visibleWithin: Duration = DEFAULT_VISIBLE_WITHIN, dispatcher: CoroutineDispatcher = VirtualThreads.dispatcher)