This is an automated email from the ASF dual-hosted git repository. lizhimin pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push: new 46b7a98de0 [ISSUE #9403] Fix the issue of metadata synchronization failure between master and slave when the topic has attributes (#9404) 46b7a98de0 is described below commit 46b7a98de020db637cfc1112010fec1f9c999bb7 Author: rongtong <jinrongton...@mails.ucas.ac.cn> AuthorDate: Tue May 20 10:35:25 2025 +0800 [ISSUE #9403] Fix the issue of metadata synchronization failure between master and slave when the topic has attributes (#9404) --- .../main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 f75fd21610..ee716a565d 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 @@ -99,8 +99,8 @@ public class SlaveSynchronize { } //update - newTopicConfigTable.values().forEach(topicConfigManager::updateSingleTopicConfigWithoutPersist); - + newTopicConfigTable.values().forEach(topicConfigManager::putTopicConfig); + topicConfigManager.updateDataVersion(); topicConfigManager.persist(); } if (topicWrapper.getTopicQueueMappingDetailMap() != null