imaffe opened a new issue #612: URL: https://github.com/apache/rocketmq-externals/issues/612
The issue tracker is **ONLY** used for bug report and feature request. Any question or RocketMQ proposal please use our [mailing lists](http://rocketmq.apache.org/about/contact/). **BUG REPORT** 1. Please describe the issue you observed: 1. when a task is paused, we expect it to stop fetching data from RocketMQ, however in current implementation, the paused tasks are fetching data and discarding them, which would lead to data lose (and user wouldn't expect to lose data when they click a pause button) ``` if (pullResult.getPullStatus().equals(PullStatus.FOUND)) { final List<MessageExt> messages = pullResult.getMsgFoundList(); // removePausedQueueMessages receiveMessages(messages); messageQueuesOffsetMap.put(entry.getKey(), pullResult.getNextBeginOffset()); offsetData.put(convertToByteBufferKey(entry.getKey()), convertToByteBufferValue(pullResult.getNextBeginOffset())); preCommit(); } ``` ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
