GenerousMan opened a new issue, #4725: URL: https://github.com/apache/rocketmq/issues/4725
In the current POP consumption mode, the InvisibleTime implementation of the CK/ACK message relies on the scheduled message. However, because of the precision limitation of the scheduled message, some CK/ACK messages may work not as expected. Since the completion of RIP-43, rocketmq can already support timing messages with arbitrary delay. Therefore, using this feature can optimize the POP consumption process. To make the explanation clearer, I put diagrams in this doc: https://shimo.im/docs/1d3aVVaNjeTPB7qg/ To achieve it, the following modifications need to be made: - [ ] Modify the function SetMessageDeliverTimer and getMessageDeliverTimer. - [ ] Supplement the unit tests of PopReviveService, make sure the pipeline works well. -- 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]
