程序包 | 说明 |
---|---|
wang.bigbird.domain.framework.data.kafka | |
wang.bigbird.domain.framework.data.kafka.base.helper |
限定符和类型 | 方法和说明 |
---|---|
org.springframework.kafka.core.ProducerFactory |
KafkaConfiguration.kafkaProducerFactory(KafkaProducerProperties kafkaProducerProperties,
KafkaConsumerProperties kafkaConsumerProperties,
org.springframework.boot.autoconfigure.kafka.KafkaProperties springKafkaProperties)
生产者工厂
|
限定符和类型 | 方法和说明 |
---|---|
static void |
PropertiesHelper.combineKafkaProperties(KafkaProducerProperties kafkaProducerProperties,
KafkaConsumerProperties kafkaConsumerProperties,
org.springframework.boot.autoconfigure.kafka.KafkaProperties springKafkaProperties)
合并kafka配置
配置加载优先级如下:
1、自定义配置优先
2、spring原生配置作为候补
|