[rocketmq] branch develop updated: [ISSUE #4170] Fix getEarliestMessageTime in DLedger mode (#4168)

[yu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

yuzhou pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new d1f812491 [ISSUE #4170] Fix getEarliestMessageTime in DLedger mode (#4168)
d1f812491 is described below

commit d1f8124919f3a4dfec072b4e2583ed76ed5f0c0a
Author: cnScarb <jj...@163.com>
AuthorDate: Wed Apr 20 23:07:38 2022 +0800

    [ISSUE #4170] Fix getEarliestMessageTime in DLedger mode (#4168)
---
 .../main/java/org/apache/rocketmq/store/DefaultMessageStore.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
index 30cf36c50..ea9b3e763 100644
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -16,6 +16,7 @@
  */
 package org.apache.rocketmq.store;
 
+import io.openmessaging.storage.dledger.entry.DLedgerEntry;
 import java.io.File;
 import java.io.IOException;
 import java.io.RandomAccessFile;
@@ -911,7 +912,10 @@ public class DefaultMessageStore implements MessageStore {
 
     @Override
     public long getEarliestMessageTime() {
-        final long minPhyOffset = this.getMinPhyOffset();
+        long minPhyOffset = this.getMinPhyOffset();
+        if (this.getCommitLog() instanceof DLedgerCommitLog) {
+            minPhyOffset += DLedgerEntry.BODY_OFFSET;
+        }
         final int size = this.messageStoreConfig.getMaxMessageSize() * 2;
         return this.getCommitLog().pickupStoreTimestamp(minPhyOffset, size);
     }