diff --git a/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java b/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java index f8c33180..34757c62 100644 --- a/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java +++ b/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java @@ -183,7 +183,7 @@ public class RocketMQEventConfiguration { */ @Slf4j @Component - @RocketMQMessageListener(topic = "topic_construction_area_${spring.profiles.active]", + @RocketMQMessageListener(topic = "topic_construction_area_${spring.profiles.active}", consumerGroup = "GID_construction_area_${spring.application.name}_${spring.profiles.active}", consumeMode = ConsumeMode.ORDERLY, nameServer = "${rocketmq.name-server}")