KafkaMessageBroker

constructor(consumerProps: Map<String, Any>? = null, producerProps: Map<String, Any>? = null, keyClass: Class<K>, valClass: Class<V>, needSubscribe: Boolean = true)