nodece opened a new pull request, #16171: URL: https://github.com/apache/pulsar/pull/16171
Signed-off-by: Zixuan Liu <[email protected]> Master Issue: #<xyz> ### Motivation When subscribing to a message on a partitioned topic, do the seek operation and then consume the messages, which sometimes will receive duplicate messages. The root cause is that when a seek operation is performed if have the task in the `pendingReceives` queue, we will get old messages from before doing the seek operation. ### Modifications - Add a seek check to the logic of the received message, wthe seek operation is in progress, skip put the message to `incomingMessages` queue ### Verifying this change `org.apache.pulsar.broker.service.SubscriptionSeekTest#testSeekByFunctionAndMultiTopic` cover this changes. ### Documentation - [x] `doc-not-needed` -- 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]
