-
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
PIP-105 add support for updating the Subscription properties #15751
PIP-105 add support for updating the Subscription properties #15751
Conversation
6b2a488
to
90c3dd2
Compare
24dbf27
to
77cdfcb
Compare
/pulsarbot rerun-failure-checks |
/pulsar-bot rerun-failure-checks |
…-subscription-properties
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 added a comment about making the REST API more RESTful.
I would also like to suggest implementing the GET for retrieving current properties.
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.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.
Some minor log message changes. One of them mentions deleting subscription.
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
Outdated
Show resolved
Hide resolved
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
Outdated
Show resolved
Hide resolved
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
Outdated
Show resolved
Hide resolved
Co-authored-by: Lari Hotari <lhotari@users.noreply.github.com>
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
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
if (!isRedirectException(ex)) { | ||
log.error("[{}] Failed to update subscription {} from topic {}", | ||
clientAppId(), subName, topicName, ex); | ||
} |
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.
We will not get a RedirectException here?
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 will double check, this code is basically copy/pasted from resetCursor IIRC
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.
it should come from here
pulsar/pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java
Line 732 in eb1daae
throw new WebApplicationException(Response.temporaryRedirect(redirect).build()); |
in validateTopicOwnershipAsync
* PIP-105 add support for updating the Subscription properties * Implement command update-subscription-properties * Add tests * Add volatile * Fix PersistentTopicTest * PIP-105: Store Subscription properties * Fix FilterEntryTest * Add volatile * Fix PersistentTopicTest * fix ServerCnxTest test * Switch from POST to PUT * rename to /properties * Apply suggestions from code review Co-authored-by: Lari Hotari <lhotari@users.noreply.github.com> Co-authored-by: Lari Hotari <lhotari@users.noreply.github.com> (cherry picked from commit 8e77e88)
…15751) * PIP-105 add support for updating the Subscription properties * Implement command update-subscription-properties * Add tests * Add volatile * Fix PersistentTopicTest * PIP-105: Store Subscription properties * Fix FilterEntryTest * Add volatile * Fix PersistentTopicTest * fix ServerCnxTest test * Switch from POST to PUT * rename to /properties * Apply suggestions from code review Co-authored-by: Lari Hotari <lhotari@users.noreply.github.com> Co-authored-by: Lari Hotari <lhotari@users.noreply.github.com> (cherry picked from commit 8e77e88) (cherry picked from commit 9dd4057)
… test (cherry picked from commit 23b41cb)
Motivation:
Modifications:
Docs:
Documentation for pulsar-admin and for the REST API are automatically generated