merlimat opened a new pull request #1818: Fixed race condition in consumer event listener URL: https://github.com/apache/incubator-pulsar/pull/1818 ### Motivation Fixes #1614 #1617 The flaky test was actually because of a race condition in the dispatcher code. If there is a pending read when the consumer is switched, the actual switch happens after the read completes, but the dispatcher wouldn't trigger the notification at that point. ### Modifications Ensure the active/inactive notification is sent after the read completes.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
