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

Reply via email to