eolivelli opened a new pull request, #16812: URL: https://github.com/apache/pulsar/pull/16812
Changes: sendMessagesToConsumer must block reads of new entries otherwise we will end up in reading duplicates Fixes #16802 ### Motivation As described in #16802 it may happen that multiple calls to `readMoreEntries` are served before the execution of `sendMessagesToConsumer` Unfortunately there is no control over the execution of `readMoreEntries`, it may happen in many different threadpools ### Modifications Add a flag to prevent concurrent execution of `sendMessagesToConsumer` with `readMoreEntries`. Revert aa change to a test modified in #16802 to make the test pass ### Verifying this change This change is already covered by existing tests -- 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]
