替换消费者组

src/main/java/com/zzsn/leaderbase/kafka/PersonOfJobChangeKafkaConsumer.java

@@ -41,7 +41,7 @@ public class PersonOfJobChangeKafkaConsumer {
     private String USERSERVER_BASEDATA = "userserver_basedata";
 
 
-    @KafkaListener(topics = "personOfJobChangeTopic", groupId = "group02")
+    @KafkaListener(topics = "personOfJobChangeTopic", groupId = "personGroup")
     public void listen(String message) {
         log.info("kafka pull personOfJobChangeTopic: {} ......", message.substring(0,30));
         getData(message);