diff --git a/backend/services/api-test/src/main/java/io/metersphere/api/config/KafkaConfig.java b/backend/services/api-test/src/main/java/io/metersphere/api/config/KafkaConfig.java index f48a1461d0..2cda83f10e 100644 --- a/backend/services/api-test/src/main/java/io/metersphere/api/config/KafkaConfig.java +++ b/backend/services/api-test/src/main/java/io/metersphere/api/config/KafkaConfig.java @@ -20,7 +20,7 @@ public class KafkaConfig { @Autowired public KafkaConfig(KafkaProperties kafkaProperties) { - ProducerFactory producerFactory = new DefaultKafkaProducerFactory<>(kafkaProperties.buildProducerProperties()); + ProducerFactory producerFactory = new DefaultKafkaProducerFactory<>(kafkaProperties.buildProducerProperties(null)); defaultMap = producerFactory.getConfigurationProperties(); }