We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7b85a5d commit 559f389Copy full SHA for 559f389
store/src/main/java/org/apache/rocketmq/store/config/StorePathConfigHelper.java
@@ -32,7 +32,7 @@ public static String getStorePathBatchConsumeQueue(final String rootDir) {
32
}
33
34
public static String getStorePathRocksDBConsumeQueue(final String rootDir) {
35
- return rootDir + File.separator + "consumequeue_r";
+ return rootDir + File.separator + "consumequeue_rocksdb";
36
37
38
public static String getStorePathIndex(final String rootDir) {
0 commit comments