抖小更改及监测

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

@@ -25,19 +25,19 @@ import java.util.Map;
 @EnableKafka
 public class KafkaConsumerConfig {
 
-    @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.novel.active.group_id}")
     private String groupId;
 
-    @Value("${spring.kafka2.consumer.max-poll-records}")
+    @Value("${spring.kafka.consumer.max-poll-records}")
     private int maxPollRecordsConfig;
 
 

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

@@ -25,19 +25,19 @@ import java.util.Map;
 @EnableKafka
 public class KafkaStoreConsumerConfig {
 
-    @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.novel.storeActive.group_id}")
     private String groupId;
 
-    @Value("${spring.kafka2.consumer.max-poll-records}")
+    @Value("${spring.kafka.consumer.max-poll-records}")
     private int maxPollRecordsConfig;
 
 

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

@@ -24,19 +24,19 @@ import java.util.Map;
 @EnableKafka
 public class VideoAppActiveKafkaConsumerConfig {
 
-    @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.active.group_id}")
     private String groupId;
 
-    @Value("${spring.kafka2.consumer.max-poll-records}")
+    @Value("${spring.kafka.consumer.max-poll-records}")
     private int maxPollRecordsConfig;