From 47175d88c60738157ae57fa5b2fde2563180ca34 Mon Sep 17 00:00:00 2001
From: zhangjidi2016 <zhangjidi@cmss.chinamobile.com>
Date: Sun, 25 Jul 2021 16:52:23 +0800
Subject: [PATCH] use dLegerSelfId instead of brokerId in dleger mode

---
 .../main/java/org/apache/rocketmq/broker/BrokerStartup.java    | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
index 96e43d1126..84243c907b 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
@@ -188,6 +188,9 @@ public class BrokerStartup {
             configurator.setContext(lc);
             lc.reset();
             System.setProperty("brokerLogDir", brokerConfig.getBrokerName() + "_" + brokerConfig.getBrokerId());
+            if (messageStoreConfig.isEnableDLegerCommitLog()) {
+                System.setProperty("brokerLogDir", brokerConfig.getBrokerName() + "_" + messageStoreConfig.getdLegerSelfId());
+            }
             configurator.doConfigure(brokerConfig.getRocketmqHome() + "/conf/logback_broker.xml");
 
             if (commandLine.hasOption('p')) {