-
Notifications
You must be signed in to change notification settings - Fork 3.7k
[Broker] Fix call sync method in async rest api for internalGetLastMessageId #13882
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
[Broker] Fix call sync method in async rest api for internalGetLastMessageId #13882
Conversation
|
@gaozhangmin:Thanks for your contribution. For this PR, do we need to update docs? |
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
Show resolved
Hide resolved
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
Show resolved
Hide resolved
|
/pulsarbot run-failure-checks |
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
Outdated
Show resolved
Hide resolved
08cca65 to
b82cc5e
Compare
| if (!(topic instanceof PersistentTopic)) { | ||
| log.error("[{}] Not supported operation of non-persistent topic {}", clientAppId(), topicName); | ||
| asyncResponse.resume(new RestException(Status.METHOD_NOT_ALLOWED, | ||
| "GetLastMessageId on a non-persistent topic is not allowed")); |
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 a return here.
|
@gaozhangmin When submitting a PR, can you provide doc-related info (tick the box) in the PR description? So that Bot can recognize and label your PR correspondingly. Or else Bot labels your PR with You can check the instructions for doc labels here |
Master Issue: #13854
Motivation
Avoid call sync method in async rest API for PersistentTopicsBase#internalGetLastMessageId.
Documentation
Check the box below or label this PR directly (if you have committer privilege).
Need to update docs?
doc-required(If you need help on updating docs, create a doc issue)
no-need-doc(Please explain why)
doc(If this PR contains doc changes)