kafkaEndpoint

val kafkaEndpoint: String? = null