RockteMQ-AI commented on issue #1323: URL: https://github.com/apache/rocketmq-clients/issues/1323#issuecomment-5440303909
**Issue Evaluation** Category: bug | Status: **Confirmed** This is a valid bug. The Go client PushConsumer leaks inflight receive request count when MESSAGE_NOT_FOUND is returned — the counter is incremented on request start but not decremented on this specific response path. Over time this causes the consumer to stall as the inflight counter reaches the max. **Root Cause:** Missing decrement of inflight counter in the MESSAGE_NOT_FOUND response handler. **Impact:** Consumer gradually stops receiving messages after enough MESSAGE_NOT_FOUND responses. **Severity:** High — causes message consumption to stall. --- *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]
