public class PropertiesHelper extends Object
构造器和说明 |
---|
PropertiesHelper() |
限定符和类型 | 方法和说明 |
---|---|
static void |
combineKafkaProperties(KafkaProducerProperties kafkaProducerProperties,
KafkaConsumerProperties kafkaConsumerProperties,
org.springframework.boot.autoconfigure.kafka.KafkaProperties springKafkaProperties)
合并kafka配置
配置加载优先级如下:
1、自定义配置优先
2、spring原生配置作为候补
|
public static void combineKafkaProperties(KafkaProducerProperties kafkaProducerProperties, KafkaConsumerProperties kafkaConsumerProperties, org.springframework.boot.autoconfigure.kafka.KafkaProperties springKafkaProperties)
配置加载优先级如下:
1、自定义配置优先
2、spring原生配置作为候补
kafkaProducerProperties
- 自定义kafka生产者属性kafkaConsumerProperties
- 自定义kafka消费者属性springKafkaProperties
- spring原生的kafka配置