diff --git a/mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java b/mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java index e027fa563..780a8e213 100644 --- a/mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java +++ b/mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java @@ -125,7 +125,7 @@ private void refresh() throws MQClientException { Set thisTopicList = new HashSet<>(); for (String topic : tmp) { try { - if (topic.equals(serviceConf.getClientRetryTopic())) { + if (topic.equals(serviceConf.getEventNotifyRetryTopic())) { // notify by RetryDriver self continue; }