No need to change to slave

a90342e9 · dongeforever · a50b733d · a90342e9
隐藏空白更改
内联并排

Showing with 1 addition and 3 deletion

broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java ...ain/java/org/apache/rocketmq/broker/BrokerController.java +1 -3

未找到文件。
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -806,9 +806,7 @@ public class BrokerController {
            this.filterServerManager.start();
        }
-        if (messageStoreConfig.isEnableDLegerCommitLog()) {
+        if (!messageStoreConfig.isEnableDLegerCommitLog()) {
-            changeToSlave(((DLedgerCommitLog)((DefaultMessageStore) messageStore).getCommitLog()).getId());
-        } else {
            startProcessorByHa(messageStoreConfig.getBrokerRole());
            handleSlaveSynchronize(messageStoreConfig.getBrokerRole());
        }