lhotari commented on PR #14566: URL: https://github.com/apache/pulsar/pull/14566#issuecomment-3562260828
This seems to make the client behave in the wrong way for multi-topic consumer. Before this change, the client would first subscribe to all topics and then send flow permits to the broker in the startReceivingMessages method. The behavior change is that messages will start flowing from the broker to the client immediately. If subscribing to any of the partitions fails, it will add a lot of extra work to the system and could cause cascading failures when brokers are at their limits. It's better to fix this problem and remove the `newConsumer.resume();` lines added in this PR. -- 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]
