diff --git a/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java b/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
index 64564de8..4063b79e 100644
--- a/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
+++ b/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
@@ -88,7 +88,7 @@ public class RocketMQEventConfiguration {
     @Slf4j
     @Component
     @RocketMQMessageListener(topic = "%RETRY%GID_topic_thrones_${spring.profiles.active}",
-            consumerGroup = "GID_topic_thrones_${spring.application.name}_${spring.profiles.active}",
+            consumerGroup = "GID_topic_thrones_retry_${spring.application.name}_${spring.profiles.active}",
             messageModel = MessageModel.BROADCASTING,
             nameServer = "${rocketmq.name-server}"
     )
@@ -130,7 +130,7 @@ public class RocketMQEventConfiguration {
     @Slf4j
     @Component
     @RocketMQMessageListener(topic = "%RETRY%GID_topic_tyr_${spring.profiles.active}",
-            consumerGroup = "GID_topic_tyr_${spring.application.name}_${spring.profiles.active}",
+            consumerGroup = "GID_topic_tyr_retry_${spring.application.name}_${spring.profiles.active}",
             messageModel = MessageModel.BROADCASTING,
             nameServer = "${rocketmq.name-server}"
     )
@@ -176,7 +176,7 @@ public class RocketMQEventConfiguration {
     @Slf4j
     @Component
     @RocketMQMessageListener(topic = "%RETRY%GID_topic_apisix_plat_${spring.profiles.active}",
-            consumerGroup = "GID_topic_apisix_plat_${spring.application.name}_${spring.profiles.active}",
+            consumerGroup = "GID_topic_apisix_plat_retry_${spring.application.name}_${spring.profiles.active}",
             messageModel = MessageModel.BROADCASTING,
             nameServer = "${rocketmq.name-server}"
     )