diff --git a/store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java b/store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java index 2f4dcf5c5ba..c4b4ddcf9c6 100644 --- a/store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java +++ b/store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java @@ -137,7 +137,7 @@ public void recover() { log.info("recover next consume queue file, " + mappedFile.getFileName()); } } else { - log.info("recover current consume queue queue over " + mappedFile.getFileName() + " " + log.info("recover current consume queue over " + mappedFile.getFileName() + " " + (processOffset + mappedFileOffset)); break; }