-
Notifications
You must be signed in to change notification settings - Fork 3.6k
New issue
Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? # to your account
[improve] [broker] Check max producers/consumers limitation first before other ops to save resources #23074
[improve] [broker] Check max producers/consumers limitation first before other ops to save resources #23074
Conversation
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
Outdated
Show resolved
Hide resolved
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.
Good catch, LGTM.
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
Outdated
Show resolved
Hide resolved
pulsar-broker/src/test/java/org/apache/pulsar/client/api/MaxProducerTest.java
Show resolved
Hide resolved
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## master #23074 +/- ##
============================================
- Coverage 73.57% 73.45% -0.13%
- Complexity 32624 33212 +588
============================================
Files 1877 1917 +40
Lines 139502 144077 +4575
Branches 15299 15741 +442
============================================
+ Hits 102638 105828 +3190
- Misses 28908 30133 +1225
- Partials 7956 8116 +160
Flags with carried forward coverage won't be shown. Click here to find out more.
|
…ore other ops to save resources (apache#23074) (cherry picked from commit 679a3d4) (cherry picked from commit f08a34c)
…ore other ops to save resources (apache#23074) (cherry picked from commit 679a3d4) (cherry picked from commit f08a34c)
…ore other ops to save resources (apache#23074)
Motivation
Background
Issue
Modifications
Documentation
doc
doc-required
doc-not-needed
doc-complete
Matching PR in forked repository
PR in forked repository: x