update

examcloud-core-reports-api-provider/src/main/java/cn/com/qmth/examcloud/core/reports/api/listener/RocketMqConsumerListener.java

@@ -47,7 +47,7 @@ public class RocketMqConsumerListener {
     }
 
     private static void onlineExamStudent() {
-        properties.put(PropertyKeyConst.GROUP_ID, Tag.ONLINE_EXAM_STUDENT.getGroup() + ReportsUtil.getProfile());
+        properties.put(PropertyKeyConst.GROUP_ID, Tag.ONLINE_EXAM_STUDENT.getGroup() + "_" + ReportsUtil.getProfile());
         Consumer consumer = ONSFactory.createConsumer(properties);
         consumer.subscribe(ReportsUtil.getReportTopic(), Tag.ONLINE_EXAM_STUDENT.getCode(), new MessageListener() {
 
@@ -68,7 +68,7 @@ public class RocketMqConsumerListener {
     }
 
     private static void onlineStudent() {
-        properties.put(PropertyKeyConst.GROUP_ID, Tag.ONLINE_STUDENT.getGroup() + ReportsUtil.getProfile());
+        properties.put(PropertyKeyConst.GROUP_ID, Tag.ONLINE_STUDENT.getGroup() + "_" + ReportsUtil.getProfile());
         Consumer consumer = ONSFactory.createConsumer(properties);
         consumer.subscribe(ReportsUtil.getReportTopic(), Tag.ONLINE_STUDENT.getCode(), new MessageListener() {
 
@@ -89,7 +89,7 @@ public class RocketMqConsumerListener {
     }
 
     private static void onlineUser() {
-        properties.put(PropertyKeyConst.GROUP_ID, Tag.ONLINE_USER.getGroup() + ReportsUtil.getProfile());
+        properties.put(PropertyKeyConst.GROUP_ID, Tag.ONLINE_USER.getGroup() + "_" + ReportsUtil.getProfile());
         Consumer consumer = ONSFactory.createConsumer(properties);
         consumer.subscribe(ReportsUtil.getReportTopic(), Tag.ONLINE_USER.getCode(), new MessageListener() {
 
@@ -110,7 +110,7 @@ public class RocketMqConsumerListener {
     }
 
     private static void operateInfo() {
-        properties.put(PropertyKeyConst.GROUP_ID, Tag.OPERATE_INFO.getGroup() + ReportsUtil.getProfile());
+        properties.put(PropertyKeyConst.GROUP_ID, Tag.OPERATE_INFO.getGroup() + "_" + ReportsUtil.getProfile());
         Consumer consumer = ONSFactory.createConsumer(properties);
         consumer.subscribe(ReportsUtil.getReportTopic(), Tag.OPERATE_INFO.getCode(), new MessageListener() {