Aias00 opened a new issue, #10945:
URL: https://github.com/apache/rocketmq/issues/10945

   ## Reproduction\n\nWhen POP returns more than one normal message before a 
retry-topic result, PopConsumerContext stores one GetMessageResult per fetch 
result but flattens PopConsumerRecord entries per 
message.\n\nPopConsumerService later iterates getMessageResultList by result 
index and looks up popConsumerRecordList with the same index. After a 
multi-message result, that index points into the preceding batch instead of to 
the first record for the current result.\n\nWith 
popResponseReturnActualRetryTopic enabled, a retry result can therefore be 
treated as a normal result and skip retry-message recoding.\n\n## Expected 
behavior\n\nEach fetched GetMessageResult must use the first PopConsumerRecord 
that belongs to that result when deciding whether to recode retry 
messages.\n\n## Regression 
test\n\nPopConsumerServiceTest.popAsyncRecodeRetryMessagesAfterMultiMessageNormalResultTest
 fails on current develop.


-- 
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]

Reply via email to