We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1a747d1 commit 2accb97Copy full SHA for 2accb97
1 file changed
broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
@@ -627,9 +627,6 @@ public TopicConfigAndMappingSerializeWrapper buildSerializeWrapper(
627
topicConfigWrapper.setTopicConfigTable(topicConfigTable);
628
topicConfigWrapper.setTopicQueueMappingInfoMap(topicQueueMappingInfoMap);
629
topicConfigWrapper.setDataVersion(this.getDataVersion());
630
- if (this.brokerController.getBrokerConfig().isEnableSplitRegistration()) {
631
- this.getDataVersion().nextVersion();
632
- }
633
return topicConfigWrapper;
634
}
635
0 commit comments