We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bb45b8f commit ce5a77dCopy full SHA for ce5a77d
1 file changed
broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
@@ -193,7 +193,8 @@ private void syncSubscriptionGroupConfig() {
193
subscriptionGroupManager.deleteSubscriptionGroupConfig(configEntry.getKey());
194
}
195
// update
196
- newSubscriptionGroupTable.values().forEach(subscriptionGroupManager::updateSubscriptionGroupConfigWithoutPersist);
+ newSubscriptionGroupTable.values().forEach(subscriptionGroupManager::putSubscriptionGroupConfig);
197
+ subscriptionGroupManager.updateDataVersion();
198
// persist
199
subscriptionGroupManager.persist();
200
LOGGER.info("Update slave Subscription Group from master, {}", masterAddrBak);
0 commit comments