From 71281784b1c2bc9d5ebdd6299a9fac2d9a7caedd Mon Sep 17 00:00:00 2001 From: ccwss <1782935682@qq.com> Date: Tue, 9 Sep 2025 15:33:43 +0800 Subject: [PATCH] fix sync group if attributes isn't null --- .../org/apache/rocketmq/broker/slave/SlaveSynchronize.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java b/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java index ee716a565d7..2e3134016c7 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java @@ -193,7 +193,8 @@ private void syncSubscriptionGroupConfig() { subscriptionGroupManager.deleteSubscriptionGroupConfig(configEntry.getKey()); } // update - newSubscriptionGroupTable.values().forEach(subscriptionGroupManager::updateSubscriptionGroupConfigWithoutPersist); + newSubscriptionGroupTable.values().forEach(subscriptionGroupManager::putSubscriptionGroupConfig); + subscriptionGroupManager.updateDataVersion(); // persist subscriptionGroupManager.persist(); LOGGER.info("Update slave Subscription Group from master, {}", masterAddrBak);