zhanxuefeng commented on PR #4266: URL: https://github.com/apache/rocketmq/pull/4266#issuecomment-1125612366
Test `ManyMessageTransfer` RocketMQ version: 4.9.3 tls.server.mode: enforcing transferMsgByHeap=false this is very important The topic I created has 1 writeQueueNums and 1 readQueueNums, and I send 2 msgs to the topic. I add some logs. ### PullMessageProcessor  ### ManyMessageProcessor  ### A simple pull consumer  ### Console log  ### Consume log  Similar to [ISSUE #4265](https://github.com/apache/rocketmq/issues/4265) 610 bytes and 2 msgs was found, but only transferred 413(216 header + 197 1st msg) bytes, because 768(256 capacity + 512 capacity) > 610, so the 2nd msg will not be transferred. The consume get 413 but 610(4 length + 606 data) needed, so not msg received. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
