RockteMQ-AI commented on issue #546: URL: https://github.com/apache/rocketmq-connect/issues/546#issuecomment-5487013560
**Issue Evaluation** Category: `bug` | Status: **Confirmed** The issue is valid. In `RocketMQSourceTask`, consumer data is placed into a `BlockingQueue`, but if the connector restarts before the queue is drained, all buffered messages are lost. This is a classic at-most-once delivery problem. **Root Cause:** `BlockingQueue` is in-memory only — no persistence or checkpoint before acknowledgment. **Impact:** Data loss on any connector restart or crash. **Severity:** Critical — data integrity issue. The fix should ensure offsets are only committed after data is successfully written downstream, or the queue should be drained before shutdown. --- *Automated evaluation by RockteMQ-AI* -- 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]
