-
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
[Issue 13756][Broker] Optimize topic policy with HierarchyTopicPolicies about dispatchRate #14038
Conversation
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.
I think we need a unit test for this.
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java
Outdated
Show resolved
Hide resolved
5023a43
to
626f5e0
Compare
...ar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java
Outdated
Show resolved
Hide resolved
626f5e0
to
ec76cb2
Compare
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java
Outdated
Show resolved
Hide resolved
...ar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java
Outdated
Show resolved
Hide resolved
ec76cb2
to
dfde011
Compare
/pulsarbot run-failure-checks |
...ar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java
Outdated
Show resolved
Hide resolved
f66ec1f
to
8b74270
Compare
/pulsarbot run-failure-checks |
8b74270
to
3b4b7f7
Compare
/pulsarbot run-failure-checks |
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.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.
LTGM, please take a look at penghui's comment
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
Outdated
Show resolved
Hide resolved
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java
Outdated
Show resolved
Hide resolved
@codelipenghui PTAL |
...ar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java
Show resolved
Hide resolved
ebc4b08
to
ab16e7e
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.
Great work.
@eolivelli Could you please help review this PR~ |
@codelipenghui PTAL |
de10fa0
to
f9297ea
Compare
/pulsarbot run-failure-checks |
/pulsarbot run-failure-checks |
1 similar comment
/pulsarbot run-failure-checks |
c8d361e
to
e654be4
Compare
resolve conflicting |
e654be4
to
d3eef89
Compare
/pulsarbot run-failure-checks |
Master Issue: #13756
Motivation
See issue: #13756
Modifications
dispatchRate
inorg.apache.pulsar.common.policies.data.HierarchyTopicPolicies
dispatchRate
inorg.apache.pulsar.broker.service.AbstractTopic
org.apache.pulsar.broker.service.persistent.DispatchRateLimiter
wheredispatchRate
are usedVerifying this change
Does this pull request potentially affect one of the following parts:
If
yes
was chosen, please highlight the changesDocumentation
no-need-doc