nicoloboschi opened a new pull request, #17143: URL: https://github.com/apache/pulsar/pull/17143
NOTE: THIS BUG IS NOT IN ANY RELEASED VERSION OF PULSAR. ### Motivation While using a streaming dispatcher (`streamingDispatch=true`), the consumer (with a shared subscription) is stuck and it's not able to fully read a topic. That is because after the an entry is read, the `readMoreEntries` method is not triggered anymore. This is a regression introduced in https://github.com/apache/pulsar/pull/16968 ### Modifications * Aligned the new usage of the method `sendMessagesToConsumers` in the `PersistentStreamingDispatcherMultipleConsumers` in the same way it's used in `PersistentDispatcherMultipleConsumers` * Implemented the option `DispatcherDispatchMessagesInSubscriptionThread` also in the streaming dispatcher - this might be done in another pull but it's a very tiny change The evidence of this bug is that the test a several tests with streaming enabled [are failing](https://github.com/apache/pulsar/runs/7864993203#r6) but since they are in the flaky section, they have been ignored. Now these tests are passing - [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]
