You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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
The text was updated successfully, but these errors were encountered:
Before Creating the Enhancement Request
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
The text was updated successfully, but these errors were encountered: