[ROCKETMQ-163] DefaultMQPullConsumer.java批量拉取消息最大只能拉800个

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 4.0.0-incubating
• Component/s: rocketmq-store
• Environment: linux
• Assignee: Xinyu Zhou
• Reporter: 郭中奇
• Created: 06/Apr/17 03:41
• Updated: 20/Apr/17 06:30
• Resolved: 20/Apr/17 06:30

Description

 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;
  }