zjncs opened a new pull request, #11023: URL: https://github.com/apache/rocketmq/pull/11023
Fixes #10985 ## Summary Handle exceptional completion from PopReviveService.getBizMessage so a failed asynchronous read is treated as retryable and rePutCK preserves POP redelivery. ## Root cause CompletableFuture.allOf(...).whenComplete called future.getNow on an exceptionally completed child future; getNow throws CompletionException before the checkpoint cleanup/rePutCK path runs. ## Changes Use handle on the read stage to log the failure and return (msgOffset, false), allowing existing retry checkpoint logic to run. ## Verification - git diff --check passed - Maven unavailable in environment; CI should run PopReviveServiceTest and project checks AI-assisted contribution; reviewed locally. -- 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]
