diff --git a/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java b/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java index 6019b245c9..3dd2db3e23 100644 --- a/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java +++ b/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java @@ -41,9 +41,11 @@ public class MessageStoreConfig { @ImportantField private String storePathEpochFile = null; - private String storePathMetadata = storePathRootDir + File.separator + "metadata"; + @ImportantField + private String storePathMetadata = null; - private String storePathTempMetadata = storePathRootDir + File.separator + "metadata-temp"; + @ImportantField + private String storePathTempMetadata = null; private String readOnlyCommitLogStorePaths = null; @@ -642,6 +644,9 @@ public class MessageStoreConfig { } public String getStorePathMetadata() { + if (storePathMetadata == null) { + return storePathRootDir + File.separator + "metadata"; + } return storePathMetadata; } @@ -650,6 +655,9 @@ public class MessageStoreConfig { } public String getStorePathTempMetadata() { + if (storePathTempMetadata == null) { + return storePathRootDir + File.separator + "metadata-temp"; + } return storePathTempMetadata; }