Uploaded image for project: 'Apache RocketMQ'
  1. Apache RocketMQ
  2. ROCKETMQ-163

DefaultMQPullConsumer.java批量拉取消息最大只能拉800个

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Won't Fix
    • Affects Version/s: 4.0.0-incubating
    • Fix Version/s: None
    • Component/s: rocketmq-store
    • Labels:
      None
    • Environment:
      linux

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

        Attachments

          Activity

            People

            • Assignee:
              Yukon yukon
              Reporter:
              g0715158 郭中奇
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: