Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Feature] Notify pop request before calculate consumer lag #8947

Closed
lizhimins opened this issue Nov 18, 2024 · 0 comments · Fixed by #8949
Closed

[Feature] Notify pop request before calculate consumer lag #8947

lizhimins opened this issue Nov 18, 2024 · 0 comments · Fixed by #8949

Comments

@lizhimins
Copy link
Member

Is Your Feature Request Related to a Problem?

当 RocketMQ 的 Pop 消费模式引入了按需唤醒的特性(#8269#8592)后,消费延迟滞后时间最大会达到一个长轮询的时间间隔,实际上消费过程是没有延迟的。为了更准确地反映这一情况,系统在计算消息堆积量之前会先执行一次长轮询以唤醒消费者。这一特性依赖于两个条件:1. 每写入一定数量的消息时触发唤醒;2. 在输出指标之前执行唤醒逻辑。

When the wake-up feature was introduced in RocketMQ's Pop consumption mode (issues #8269, #8592), the maximum backlog of messages is equivalent to the duration of one long poll, meaning that the actual consumption process is delay-free. To more accurately reflect this situation, the system now performs a long poll to wake up the consumer before calculating the message lag. This feature relies on two conditions: 1. Triggering a wake-up after a certain number of messages are written; 2. Executing the wake-up logic before outputting the metrics.

Describe the Solution You'd Like

Impl this feature

Describe Alternatives You've Considered

This feature relies on two conditions: 1. Triggering a wake-up after a certain number of messages are written; 2. Executing the wake-up logic before outputting the metrics.

Additional Context

No

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging a pull request may close this issue.

1 participant