kafka

src/main/java/com/lwby/marketing/conf/kafka/VideoAppBehavoirKafkaConsumerConfig.java

@@ -25,19 +25,19 @@ import java.util.Map;
 @EnableKafka
 public class VideoAppBehavoirKafkaConsumerConfig {
 
-    @Value("${spring.kafka2.bootstrap-servers}")
+    @Value("${spring.kafka.bootstrap-servers}")
     private String servers;
 
-    @Value("${spring.kafka2.consumer.enable-auto-commit}")
+    @Value("${spring.kafka.consumer.enable-auto-commit}")
     private boolean enableAutoCommit;
 
-    @Value("${spring.kafka2.consumer.auto-offset-reset}")
+    @Value("${spring.kafka.consumer.auto-offset-reset}")
     private String autoOffsetReset;
 
     @Value("${system.consumer.videoapp.behavoir.group_id}")
     private String groupId;
 
-    @Value("${spring.kafka2.consumer.max-poll-records}")
+    @Value("${spring.kafka.consumer.max-poll-records}")
     private int maxPollRecordsConfig;