-
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
[improve][client] Support MAX_ACK_GROUP_SIZE configurable #18107
[improve][client] Support MAX_ACK_GROUP_SIZE configurable #18107
Conversation
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java
Outdated
Show resolved
Hide resolved
...nt/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java
Outdated
Show resolved
Hide resolved
Please add some tests to verify the PR. |
OK , I will fix |
6540bd4
to
094121f
Compare
Fixed.PTAL,thanks!@RobertIndie |
@eolivelli @RobertIndie @AnonHxy @Jason918 @HQebupt PTAL,thanks! |
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java
Outdated
Show resolved
Hide resolved
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java
Outdated
Show resolved
Hide resolved
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java
Outdated
Show resolved
Hide resolved
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApi2Test.java
Outdated
Show resolved
Hide resolved
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApi2Test.java
Outdated
Show resolved
Hide resolved
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java
Outdated
Show resolved
Hide resolved
ce5215a
to
9cd92bc
Compare
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TopicsConsumerImplTest.java
Outdated
Show resolved
Hide resolved
pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ConsumerConfigurationData.java
Outdated
Show resolved
Hide resolved
/pulsarbot run-failure-checks |
CI all passed: lordcheng10#33 |
/pulsarbot run-failure-checks |
1 similar comment
/pulsarbot run-failure-checks |
Codecov Report
@@ Coverage Diff @@
## master #18107 +/- ##
=============================================
+ Coverage 34.91% 45.74% +10.82%
- Complexity 5707 17568 +11861
=============================================
Files 607 1574 +967
Lines 53396 128526 +75130
Branches 5712 14149 +8437
=============================================
+ Hits 18644 58789 +40145
- Misses 32119 63658 +31539
- Partials 2633 6079 +3446
Flags with carried forward coverage won't be shown. Click here to find out more.
|
The current MAX_ACK_GROUP_SIZE is fixed at 1000, increase the configuration acknowledgementsGroupSize, support MAX_ACK_GROUP_SIZE configurable: https://github.com/apache/pulsar/blob/afcdbf0e2b5fb905e1f82f0220436f8f9ec0c742/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java#L63-L64 1.Add configuration acknowledgementsGroupSize;
#18345 relies on this, so cherry-picked to branch-2.11 |
Motivation
The current MAX_ACK_GROUP_SIZE is fixed at 1000, increase the configuration acknowledgementsGroupSize, support MAX_ACK_GROUP_SIZE configurable:
pulsar/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java
Lines 63 to 64 in afcdbf0
Modifications
1.Add configuration acknowledgementsGroupSize;
Documentation
doc
doc-required
doc-not-needed
doc-complete
Matching PR in forked repository
PR in forked repository: lordcheng10#33