BewareMyPower commented on code in PR #21945:
URL: https://github.com/apache/pulsar/pull/21945#discussion_r1469616942
##########
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java:
##########
@@ -252,7 +258,7 @@ private void receiveMessageFromConsumer(ConsumerImpl<T>
consumer, boolean batchR
}
// Process the message, add to the queue and trigger listener or
async callback
messages.forEach(msg -> {
- if (isValidConsumerEpoch((MessageImpl<T>) msg)) {
+ if (isValidConsumerEpoch((MessageImpl<T>) msg) && !duringSeek)
{
Review Comment:
I think INFO log would be better. It's a rare case to come here because the
check is already done at the beginning of `receiveMessageFromConsumer`. Even if
it came here, the maximum size of `messages` is 1 or `batchMaxMessages` (by
default 1000).
--
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]
