RockteMQ-AI commented on issue #10935: URL: https://github.com/apache/rocketmq/issues/10935#issuecomment-5394939258
**Issue Evaluation** Category: `bug` | Status: **Confirmed** Well-documented issue with clear reproduction. When multiple producers share a client ID, shutting down one producer cancels the shared `HashedWheelTimer` accumulator flush task, silently breaking async sends for the remaining producers. **Root Cause:** `DefaultMQProducerImpl.shutdown()` cancels the shared accumulator timer without checking whether other active producers still depend on it. **Impact:** Silent data delay — async sends from surviving producers accumulate but never flush until the next producer creates a new timer. In production this manifests as intermittent message delivery delays. **Severity:** Medium-High The proposed fix (reference-counted shared timer, or per-producer accumulator isolation) is appropriate. The reference-counting approach is cleaner for backward compatibility. --- *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]
