-
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
Support set MaxUnackMessagesPerSubscription on topic level #7802
Support set MaxUnackMessagesPerSubscription on topic level #7802
Conversation
@MarvinCai @jianyun8023 Could you please help review this PR? |
Can I not pass @codelipenghui What do you think? |
@jianyun8023 Sound good to me, now I think there are many places pass the |
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.
No problem, great.
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
Outdated
Show resolved
Hide resolved
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/MaxUnackedMessagesTest.java
Show resolved
Hide resolved
Motivation support set MaxUnackMessagesPerSubscription on topic level Modifications Support set/get/remove MaxUnackMessagesPerSubscription policy on topic level. Verifying this change Added Unit test to verify set/get/remove MaxUnackMessagesPerSubscription policy at Topic level work as expected when Topic level policy is enabled/disabled org.apache.pulsar.broker.admin.MaxUnackedMessagesTest#testMaxUnackedMessagesOnSubscriptionApi org.apache.pulsar.broker.admin.MaxUnackedMessagesTest#testMaxUnackedMessagesOnSubscription
Motivation support set MaxUnackMessagesPerSubscription on topic level Modifications Support set/get/remove MaxUnackMessagesPerSubscription policy on topic level. Verifying this change Added Unit test to verify set/get/remove MaxUnackMessagesPerSubscription policy at Topic level work as expected when Topic level policy is enabled/disabled org.apache.pulsar.broker.admin.MaxUnackedMessagesTest#testMaxUnackedMessagesOnSubscriptionApi org.apache.pulsar.broker.admin.MaxUnackedMessagesTest#testMaxUnackedMessagesOnSubscription
### Motivation PR apache#7818 apache#7802 supports topic-level policies. But the pulsar admin cli java doc is not supported accordingly.
Motivation support set MaxUnackMessagesPerSubscription on topic level Modifications Support set/get/remove MaxUnackMessagesPerSubscription policy on topic level. Verifying this change Added Unit test to verify set/get/remove MaxUnackMessagesPerSubscription policy at Topic level work as expected when Topic level policy is enabled/disabled org.apache.pulsar.broker.admin.MaxUnackedMessagesTest#testMaxUnackedMessagesOnSubscriptionApi org.apache.pulsar.broker.admin.MaxUnackedMessagesTest#testMaxUnackedMessagesOnSubscription
### Motivation PR apache#7818 apache#7802 supports topic-level policies. But the pulsar admin cli java doc is not supported accordingly.
Motivation support set MaxUnackMessagesPerSubscription on topic level Modifications Support set/get/remove MaxUnackMessagesPerSubscription policy on topic level. Verifying this change Added Unit test to verify set/get/remove MaxUnackMessagesPerSubscription policy at Topic level work as expected when Topic level policy is enabled/disabled org.apache.pulsar.broker.admin.MaxUnackedMessagesTest#testMaxUnackedMessagesOnSubscriptionApi org.apache.pulsar.broker.admin.MaxUnackedMessagesTest#testMaxUnackedMessagesOnSubscription
### Motivation PR apache#7818 apache#7802 supports topic-level policies. But the pulsar admin cli java doc is not supported accordingly.
Motivation
support set MaxUnackMessagesPerSubscription on topic level
Modifications
Support set/get/remove MaxUnackMessagesPerSubscription policy on topic level.
Verifying this change
Added Unit test to verify set/get/remove MaxUnackMessagesPerSubscription policy at Topic level work as expected when Topic level policy is enabled/disabled
org.apache.pulsar.broker.admin.MaxUnackedMessagesTest#testMaxUnackedMessagesOnSubscriptionApi
org.apache.pulsar.broker.admin.MaxUnackedMessagesTest#testMaxUnackedMessagesOnSubscription