Polish log for reput offset

store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java

@@ -237,6 +237,9 @@ public class DefaultMessageStore implements MessageStore {
             }
         }
 
+        log.info("[SetReputOffset] maxPhysicalPosInLogicQueue={} clMaxOffset={} clConfirmedOffset={}",
+            maxPhysicalPosInLogicQueue, this.commitLog.getMaxOffset(), this.commitLog.getConfirmOffset());
+
         if (this.getMessageStoreConfig().isDuplicationEnable()) {
             this.reputMessageService.setReputFromOffset(Math.min(maxPhysicalPosInLogicQueue, this.commitLog.getConfirmOffset()));
         } else {

store/src/main/java/org/apache/rocketmq/store/dleger/DLegerCommitLog.java

@@ -117,7 +117,11 @@ public class DLegerCommitLog extends CommitLog {
     }
 
     public long getMaxOffset() {
-        return this.dLegerFileList.getMaxWrotePosition();
+        if (this.dLegerFileStore.getCommittedPos() != -1) {
+            return dLegerFileStore.getCommittedPos();
+        } else {
+            return this.dLegerFileList.getMaxWrotePosition();
+        }
     }
 
     public long remainHowManyDataToCommit() {