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

["Jaskey Lam (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/ROCKETMQ-163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965860#comment-15965860 ] 

Jaskey Lam commented on ROCKETMQ-163:
-------------------------------------

Please modify the tiltle in English and format the code in comment in "{code}" block.

Also, clarify your problem please.

> 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
>             Fix For: 4.1.0-incubating
>
>
>  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;
>                             }



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)