lizhanhui commented on code in PR #5483:
URL: https://github.com/apache/rocketmq/pull/5483#discussion_r1017683225
##########
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java:
##########
@@ -284,6 +284,13 @@ public void processConsumeResult(
List<MessageExt> msgBackFailed = new
ArrayList<>(consumeRequest.getMsgs().size());
for (int i = ackIndex + 1; i <
consumeRequest.getMsgs().size(); i++) {
MessageExt msg = consumeRequest.getMsgs().get(i);
+ // Maybe message is expired and cleaned, just ignore it.
+ if (!consumeRequest.getProcessQueue().hasMessage(msg)) {
+ log.info("Message does not exist in process queue,
skip to send it back, topic={}, "
Review Comment:
The logging content looks ambiguous...
`Message does not exist in process queue, skip to send it back, topic={},`
-->
`Message is not found in its process queue; skip send-back-procedure.`
--
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]
