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

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

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

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

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