Skip to content

Commit 3cd0290

Browse files
lollipopjinRongtongJin
authored andcommitted
Make sure to create system topics to all the brokers in ‘systemTopicClusterName’ cluster. (#9327)
1 parent 3f00836 commit 3cd0290

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -156,10 +156,6 @@ public void start() throws Exception {
156156
}
157157

158158
protected void createSysTopic() {
159-
if (this.adminService.topicExist(this.getBroadcastTopicName())) {
160-
return;
161-
}
162-
163159
String clusterName = this.getBroadcastTopicClusterName();
164160
if (StringUtils.isEmpty(clusterName)) {
165161
throw new ProxyException(ProxyExceptionCode.INTERNAL_SERVER_ERROR, "system topic cluster cannot be empty");

0 commit comments

Comments
 (0)