-
Notifications
You must be signed in to change notification settings - Fork 3.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[Broker] Disable memory limit controller for broker client and replication clients #15723
[Broker] Disable memory limit controller for broker client and replication clients #15723
Conversation
@lhotari:Thanks for your contribution. For this PR, do we need to update docs? |
@lhotari:Thanks for providing doc info! |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It looks like this is only a partial solution. We should configure all clients with the correct configuration.
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
Outdated
Show resolved
Hide resolved
@michaeljmarshall It's intentional that this PR addresses only the replication clients. That's the problem that we have faced. |
@lhotari - sorry, I completely missed the configuration name. Do you think it'll make sense long term to have this separate config? I have been thinking about consolidating client configuration in to simplify broker client configuration. |
@michaeljmarshall Good point. After all it might be worth hard coding the setting to 0 for the actual broker client + all replication clients as @merlimat suggested. The benefit of this would be that we don't unnecessarily introduce new settings which aren't useful in the end. I will revisit this PR. We can add the way to configure the limits later. |
6fb1287
to
3c277ce
Compare
…ation clients - disable memory limit by default for broker client and replication clients - restore maxPendingMessages and maxPendingMessagesAcrossPartitions when memory limit is disabled so that pre-PIP-120 default configuration is restored when limit is disabled
3c277ce
to
61d4a8c
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
we should add this to branch-2.10
…ation clients (apache#15723) - disable memory limit by default for broker client and replication clients - restore maxPendingMessages and maxPendingMessagesAcrossPartitions when memory limit is disabled so that pre-PIP-120 default configuration is restored when limit is disabled
/pulsarbot rerun-failure-checks |
…ation clients (#15723) - disable memory limit by default for broker client and replication clients - restore maxPendingMessages and maxPendingMessagesAcrossPartitions when memory limit is disabled so that pre-PIP-120 default configuration is restored when limit is disabled
- this method was missing from a56f041
Fixes #15691
Motivation
There's a performance regression in 2.10 in geo-replication since the client memory limit is enabled by default in "PIP-120: Enable client memory limit by default", #13306 .
Modifications
maxPendingMessages
&maxPendingMessagesAcrossPartitions
limits for producers to the defaults used before PIP-120 changes when the memory limit is disabled.