kafka消息不重复消费问题处理

amos-boot-utils/amos-boot-utils-message/src/main/java/com/yeejoin/amos/message/kafka/KafkaConsumerService.java

@@ -249,7 +249,7 @@ public class KafkaConsumerService {
      *
      * @param message 消息
      */
-    @KafkaListener(id = "consumerSingle",  topics = "#{'${kafka.topics}'.split(',')}", concurrency = "2")
+    @KafkaListener(id = "consumerSingle", groupId = "${kafka.station.groupId}", topics = "#{'${kafka.topics}'.split(',')}", concurrency = "2")
     public void consumerSingle(String message, Acknowledgment ack) {
         JSONObject messageObj = JSONObject.fromObject(message);
         try {

amos-boot-utils/amos-boot-utils-message/src/main/resources/application-dev.properties

@@ -114,3 +114,5 @@ kafka.auto-startup=false
 
 #浜嬩欢鍛婅瀵规帴Kafka涓婚
 queue.kafka.eventAlarm.topics=JKXT2BP-GJ-Topic-site
+
+kafka.station.groupId=shaoxing