Fix issue 165

7c7374e3 · Li Zhanhui · Zhanhui Li · 40a233aa · 7c7374e3
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java ...n/java/org/apache/rocketmq/store/DefaultMessageStore.java +1 -1

未找到文件。
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -462,7 +462,7 @@ public class DefaultMessageStore implements MessageStore {
                        long maxPhyOffsetPulling = 0;

                        int i = 0;
-                        final int maxFilterMessageCount = 16000;
+                        final int maxFilterMessageCount = Math.max(16000, maxMsgNums * ConsumeQueue.CQ_STORE_UNIT_SIZE);
                        final boolean diskFallRecorded = this.messageStoreConfig.isDiskFallRecorded();
                        for (; i < bufferConsumeQueue.getSize() && i < maxFilterMessageCount; i += ConsumeQueue.CQ_STORE_UNIT_SIZE) {
                            long offsetPy = bufferConsumeQueue.getByteBuffer().getLong();