Senrian opened a new pull request, #10117: URL: https://github.com/apache/rocketmq/pull/10117
## Description When message delivery fails in ScheduleMessageService.DeliverDelayedMessageTimerTask, the offset parameter passed to scheduleNextTimerTask was incorrect. Using nextOffset would skip the current message and potentially lose messages. ## Fix This fix changes to use currOffset to retry the current message immediately. ## Verification - Compare with version 4.9.8 which correctly passes currOffset when delivery fails - The bug causes message loss when delivery fails Fixes #9249 -- 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]
