修改组名

amos-boot-system-jxiop/amos-boot-module-jxiop-warn-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/consumer/AlarmKafkaConsumer.java

@@ -23,7 +23,7 @@ public class AlarmKafkaConsumer {
 	AlarmEventServiceImpl alarmEventServiceImpl;
 
 	// 消费者来处理消息
-	@KafkaListener(id="user1" , topics ={"${kafka.alarm.topic}"},groupId = "messageConsumerGroup")
+	@KafkaListener(id="user1" , topics ={"${kafka.alarm.topic}"},groupId = "messageConsumerGroupWarn")
     public void message1(List<ConsumerRecord<String, String>> consumerRecords, Acknowledgment ack){
         // 异步触发预警
         alarmEventServiceImpl.handleMessage(consumerRecords);

amos-boot-system-jxiop/amos-boot-module-jxiop-warn-biz/src/main/resources/application.properties

@@ -93,7 +93,7 @@ spring.elasticsearch.rest.read-timeout=30000
 
 #消费者所在组的名称
 #消费者 的broker地址
-spring.kafka.consumer.group-id=messageConsumerGroup
+spring.kafka.consumer.group-id=messageConsumerGroupWarn
 spring.kafka.consumer.bootstrap-servers=139.9.173.44:9092
 spring.kafka.consumer.enable-auto-commit=false
 spring.kafka.consumer.auto-offset-reset=earliest