diff --git a/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java b/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java
index aa4a5dd..604516e 100644
--- a/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java
+++ b/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java
@@ -25,7 +25,7 @@ import java.util.Objects;
 
 @Component
 @ConditionalOnProperty(name = "rocketmq.enabled", havingValue = "true")
-@RocketMQMessageListener(topic = "agent_down", consumerGroup = "agent_down_group")
+@RocketMQMessageListener(topic = "tongran_agent_down", consumerGroup = "tongran_agent_down_group")
 public class AgentConsumerDownListener implements RocketMQListener<String> {
 
 	protected final SessionManager sessionManager;