-
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
[feature][broker] Support autoSubscriptionCreation
on topic level
#17720
[feature][broker] Support autoSubscriptionCreation
on topic level
#17720
Conversation
autoSubscriptionCreation
on topic level
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
Show resolved
Hide resolved
pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/TopicPolicies.java
Show resolved
Hide resolved
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/HierarchyTopicPolicies.java
Outdated
Show resolved
Hide resolved
Codecov Report
@@ Coverage Diff @@
## master #17720 +/- ##
=========================================
Coverage ? 23.64%
Complexity ? 4757
=========================================
Files ? 685
Lines ? 67385
Branches ? 7218
=========================================
Hits ? 15930
Misses ? 49096
Partials ? 2359
Flags with carried forward coverage won't be shown. Click here to find out more. |
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
But BrokerService#isAllowAutoSubscriptionCreation(org.apache.pulsar.common.naming.TopicName)
can be optimized with HierarchyTopicPolicies
in future PR.
Motivation
Current pulsar only support to set
autoSubscriptionCreation
on broker and namespace level, but we can further set this policy on the topic level.Modifications
handleSubscribe
in ServerCnx need to check autoSubscriptionCreation policy of topicDocumentation
doc-not-needed
Matching PR in forked repository
PR in forked repository: