RockteMQ-AI commented on issue #10949: URL: https://github.com/apache/rocketmq/issues/10949#issuecomment-5308116272
**Issue Evaluation** Category: `enhancement` | Status: **Evaluated** **Feasibility:** Feasible **Scope:** `PopConsumerService`, `PopConsumerCache`, offset management in broker **Compatibility:** No breaking changes — additive background task The analysis is well-grounded. With `popConsumerKVServiceEnable = true`, the offset commit rides on pop requests and there is no broker-side convergence path once consumers go idle. The proposed periodic task in `PopConsumerService` that advances `offsetTable` toward `pullOffsetTable` (bounded by the minimum in-flight offset in cache) is a sound approach. Key considerations for implementation: - The convergence task should respect `enablePopBufferMerge` semantics for both paths - Bounding by `getMinOffsetInBuffer()` ensures no premature advancement past in-flight acks - The task interval should be configurable to balance responsiveness vs. broker load This is a good improvement to offset accuracy. An automated fix proposal can be generated if the community confirms. --- *Automated evaluation by github-manager-bot* -- 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]
