(rocketmq) branch develop updated: Make sure to create system topics to all the brokers in ‘systemTopicClusterName’ cluster. (#9327)

[lollipop]

This is an automated email from the ASF dual-hosted git repository.

lollipop 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 9adff6a39e Make sure to create system topics to all the brokers in 
‘systemTopicClusterName’ cluster. (#9327)
9adff6a39e is described below

commit 9adff6a39e431e4c4707f7159f6bfc34d06ac421
Author: Jixiang Jin <lolli...@apache.org>
AuthorDate: Wed Apr 16 15:30:55 2025 +0800

    Make sure to create system topics to all the brokers in 
‘systemTopicClusterName’ cluster. (#9327)
---
 .../proxy/service/sysmessage/AbstractSystemMessageSyncer.java         | 4 ----
 1 file changed, 4 deletions(-)

diff --git 
a/proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java
 
b/proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java
index 734fbeba1b..6c19edf2f8 100644
--- 
a/proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java
+++ 
b/proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java
@@ -156,10 +156,6 @@ public abstract class AbstractSystemMessageSyncer 
implements StartAndShutdown, M
     }
 
     protected void createSysTopic() {
-        if (this.adminService.topicExist(this.getBroadcastTopicName())) {
-            return;
-        }
-
         String clusterName = this.getBroadcastTopicClusterName();
         if (StringUtils.isEmpty(clusterName)) {
             throw new ProxyException(ProxyExceptionCode.INTERNAL_SERVER_ERROR, 
"system topic cluster cannot be empty");