You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2026/07/10 10:10:07 UTC
(rocketmq) branch develop updated: [ISSUE #10604] Fix TopicConfig DataVersion not persisted in split registration (#10605)
This is an automated email from the ASF dual-hosted git repository.
lizhimins 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 c4ce550a57 [ISSUE #10604] Fix TopicConfig DataVersion not persisted in split registration (#10605)
c4ce550a57 is described below
commit c4ce550a574e938fffd5f3b50b1c564eef426439
Author: imzs <im...@foxmail.com>
AuthorDate: Fri Jul 10 18:09:59 2026 +0800
[ISSUE #10604] Fix TopicConfig DataVersion not persisted in split registration (#10605)
---
.../main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java b/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
index 488cedef79..4b82aacb07 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
@@ -648,7 +648,7 @@ public class TopicConfigManager extends ConfigManager {
topicConfigWrapper.setTopicQueueMappingInfoMap(topicQueueMappingInfoMap);
topicConfigWrapper.setDataVersion(this.getDataVersion());
if (this.brokerController.getBrokerConfig().isEnableSplitRegistration()) {
- this.getDataVersion().nextVersion();
+ updateDataVersion();
}
return topicConfigWrapper;
}