RockteMQ-AI commented on issue #1323: URL: https://github.com/apache/rocketmq-clients/issues/1323#issuecomment-5394967386
**Issue Evaluation** Category: `bug` | Status: **Confirmed** Well-documented resource leak. When `MESSAGE_NOT_FOUND` is returned, the inflight receive request counter is not decremented, causing the counter to grow unboundedly. Combined with the GracefulStop waiting for all inflight requests to complete, this results in shutdown always timing out. **Root Cause:** Missing inflight counter decrement on `MESSAGE_NOT_FOUND` response path in Go SDK PushConsumer. **Impact:** (1) Inflight counter leaks, eventually blocking new receive requests. (2) GracefulStop always waits full timeout, making clean shutdown impossible. **Severity:** High (resource leak + shutdown hang) **Suggested fix:** Ensure the inflight counter is decremented in all response paths (success, not-found, error) using `defer` or explicit cleanup in each branch. --- *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]
