-
Notifications
You must be signed in to change notification settings - Fork 3.7k
[Broker] Make PersistentTopicsBase#terminate async #14064
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
Conversation
Motivation See apache#14013 Modification * Make PersistentTopicsBase#terminate async Signed-off-by: Zike Yang <[email protected]>
Signed-off-by: Zike Yang <[email protected]>
Signed-off-by: Zike Yang <[email protected]>
|
/pulsarbot run-failure-checks |
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
Outdated
Show resolved
Hide resolved
Signed-off-by: Zike Yang <[email protected]>
Signed-off-by: Zike Yang <[email protected]>
| @PathParam("topic") @Encoded String encodedTopic, | ||
| @ApiParam(value = "Is authentication required to perform this operation") | ||
| @QueryParam("authoritative") @DefaultValue("false") boolean authoritative) { | ||
| validatePersistentTopicName(tenant, namespace, encodedTopic); |
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.
need catch exception
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 don't need to. The exception it throws is of type RestException.
|
The pr had no activity for 30 days, mark with Stale label. |
|
The pr had no activity for 30 days, mark with Stale label. |
|
These changes have been moved to #16227 . So close this PR. |
Master Issue: #14013
Motivation
See #14013
Modifications
Verifying this change
This change is a trivial rework / code cleanup without any test coverage.
Documentation
no-need-doc