[ https://issues.apache.org/jira/browse/ROCKETMQ-163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
yukon closed ROCKETMQ-163. -------------------------- Resolution: Won't Fix > DefaultMQPullConsumer.java批量拉取消息最大只能拉800个 > ----------------------------------------- > > Key: ROCKETMQ-163 > URL: https://issues.apache.org/jira/browse/ROCKETMQ-163 > Project: Apache RocketMQ > Issue Type: Bug > Components: rocketmq-store > Affects Versions: 4.0.0-incubating > Environment: linux > Reporter: 郭中奇 > Assignee: yukon > > {code} > final int MaxFilterMessageCount = 16000; > final boolean diskFallRecorded = this.messageStoreConfig.isDiskFallRecorded(); > for (; i < bufferConsumeQueue.getSize() && i < MaxFilterMessageCount; i += > ConsumeQueue.CQStoreUnitSize) { > long offsetPy = bufferConsumeQueue.getByteBuffer().getLong(); > int sizePy = bufferConsumeQueue.getByteBuffer().getInt(); > long tagsCode = bufferConsumeQueue.getByteBuffer().getLong(); > maxPhyOffsetPulling = offsetPy; > if (nextPhyFileStartOffset != Long.MIN_VALUE) { > if (offsetPy < nextPhyFileStartOffset) > continue; > } > {code} -- This message was sent by Atlassian JIRA (v6.3.15#6346)