mq一个消费者组订阅一个主题

4dkankan-center-modeling/src/main/java/com/fdkankan/modeling/receiver/BuildSceneMQListener.java

@@ -56,7 +56,7 @@ import static com.fdkankan.push.PushMessageConfig.*;
         messageModel = MessageModel.CLUSTERING,consumeMode = ConsumeMode.ORDERLY)
 public class BuildSceneMQListener implements RocketMQListener<String> {
 
-    @Value("${rocketmq.consumer.group}")
+    @Value("${rocketmq.consumer.build-scene-group}")
     private String consumerGroup;
 
     @Value("${rocketmq.build-scene.topicName.topic-modeling-a}")

4dkankan-center-scene/src/main/java/com/fdkankan/scene/listener/BuildSceneResultMQListener.java

@@ -39,7 +39,7 @@ import java.util.Objects;
         messageModel = MessageModel.CLUSTERING)
 public class BuildSceneResultMQListener implements RocketMQListener<String> {
 
-    @Value("${rocketmq.consumer.group}")
+    @Value("${rocketmq.consumer.build-scene-result-group}")
     private String consumerGroup;
 
     @Value("${rocketmq.build-scene-result.topicName.topic-modeling-a}")