KafkaCluster

constructor(kafkaConfigMap: KafkaConfigMap, schemaRegistryUrl: String? = null, coroutineContext: CoroutineContext = Dispatchers.Default)