Update

apache · Jan 13, 2025 · 65779b2 · 65779b2
1 parent 6a47b12
commit 65779b2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java b/broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java
@@ -91,7 +91,7 @@ public void handle(ConsumerGroupEvent event, String group, Object... args) {
                             this.brokerController.getBroker2Client().notifyConsumerIdsChanged(chl, group);
                         }
                         if (isNormalCompletion) {
-                            activeGroupNotifyMap.remove(group);
+                            activeGroupNotifyMap.computeIfPresent(group, (k, val) -> val == currentNotifyTaskControl ? null : val);
                         }
                     } else {
                         consumerChannelMap.put(group, channels);