KafkaDepot

constructor(brokers: Array<String>? = null, schemaRegistryUrl: String? = null, params: Map<String, Any>? = null)