chore: 替换废弃的方法
This commit is contained in:
parent
faafea471f
commit
a587b7bcb5
|
@ -20,7 +20,7 @@ public class KafkaConfig {
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
public KafkaConfig(KafkaProperties kafkaProperties) {
|
public KafkaConfig(KafkaProperties kafkaProperties) {
|
||||||
ProducerFactory<String, String> producerFactory = new DefaultKafkaProducerFactory<>(kafkaProperties.buildProducerProperties());
|
ProducerFactory<String, String> producerFactory = new DefaultKafkaProducerFactory<>(kafkaProperties.buildProducerProperties(null));
|
||||||
defaultMap = producerFactory.getConfigurationProperties();
|
defaultMap = producerFactory.getConfigurationProperties();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue