RockteMQ-AI commented on issue #1340: URL: https://github.com/apache/rocketmq-clients/issues/1340#issuecomment-5394950880
**Issue Evaluation** Category: `bug` | Status: **Confirmed** Well-analyzed throughput degradation. The fixed 1-second backoff after cache-full pause is wasteful when consumption drains the cache quickly — especially with many assigned queues and small per-queue quotas. **Root Cause:** `ProcessQueueImpl.receiveMessage` uses a fixed delay timer after cache-full pause; cache eviction (ACK/NACK) does not signal the paused receive loop to resume immediately. **Impact:** Consumer throughput degrades as queue assignment grows, despite available cache capacity. **Severity:** Medium **Suggested approach:** Add a cache-drain signal that the ACK/NACK path can trigger to wake the paused receive loop immediately, bypassing the fixed delay. --- *Automated evaluation by github-manager* -- 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]
