Kafka

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