lizhimins opened a new issue, #8592:
URL: https://github.com/apache/rocketmq/issues/8592

   ### Before Creating the Enhancement Request
   
   - [X] I have confirmed that this should be classified as an enhancement 
rather than a bug/feature.
   
   
   ### Summary
   
   当顺序消息消费阻塞时,相同的队列又有新的消息写入,此时 rest num 大于 0 造成了 pop message processor 
又重新唤醒长轮询。此时长轮询在 process 逻辑反复处理,造成有堆积消息但无法消费的情况。由于此时是顺序消费,服务端没有收到之前消息的 
ack,因此消费延迟是符合预期的,只是 cpu 使用率会偏高,可以通过优化减少反复唤起长轮询。
   
   When order message consumption is blocked, new messages are written to the 
same queue, and the rest num is greater than 0, causing the pop message 
processor to wake up the long polling again. Long polling is repeatedly 
processed in the process logic, resulting in a situation where there are lag 
messages that cannot be consumed. Due to the order consumption at this time, 
the broker did not receive the ACK of the previous pop message, so the 
consumption delay is expected. However, the CPU usage will be high, and 
optimization can be used to reduce the repeated triggering of long polling.
   
   ### Motivation
   
   减少反复唤起长轮询造成的 CPU 使用率高。
   
   Reduce the high CPU usage caused by repeatedly invoking long polling
   
   ### Describe the Solution You'd Like
   
   Reduce the high CPU usage caused by repeatedly invoking long polling
   
   ### Describe Alternatives You've Considered
   
   not add extra rest num here
   
   ### Additional Context
   
   _No response_


-- 
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]

Reply via email to