From c72cc779c3b9c78022150830433cc86c704a94ab Mon Sep 17 00:00:00 2001
From: YanYunyang <313169664@qq.com>
Date: Wed, 12 Nov 2025 15:10:19 +0800
Subject: [PATCH] [ISSUE apache#9830] when the topicSubscribeInfoTable contains
 the topic, update the Set<MessageQueue> in the topicSubscribeInfoTable.

---
 .../client/impl/consumer/DefaultMQPushConsumerImpl.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
index 0ae779971c8..e2c47c18ded 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
@@ -1418,7 +1418,7 @@ public void persistConsumerOffset() {
     @Override
     public void updateTopicSubscribeInfo(String topic, Set<MessageQueue> info) {
         Map<String, SubscriptionData> subTable = this.getSubscriptionInner();
-        if (subTable != null) {
+        if (subTable != null || this.rebalanceImpl.topicSubscribeInfoTable.containsKey(topic)) {
             if (subTable.containsKey(topic)) {
                 this.rebalanceImpl.topicSubscribeInfoTable.put(topic, info);
             }