You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/07/07 04:56:41 UTC
[pulsar] 04/06: Fix some typos of the PersistentTopics (#11187)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 5f0b787b63bfea8a738cf8fb311ad51a05a8675c
Author: lipenghui <pe...@apache.org>
AuthorDate: Fri Jul 2 18:13:04 2021 +0800
Fix some typos of the PersistentTopics (#11187)
(cherry picked from commit 5855e0c87f3a3ee67e21db6957910092da348b8c)
---
.../java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
index 32ec02d..20e3f75 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
@@ -600,7 +600,6 @@ public class PersistentTopics extends PersistentTopicsBase {
@ApiParam(value = "Is authentication required to perform this operation")
@QueryParam("authoritative") @DefaultValue("false") boolean authoritative) {
validateTopicName(tenant, namespace, encodedTopic);
- validateTopicName(tenant, namespace, encodedTopic);
validateTopicPolicyOperation(topicName, PolicyName.MAX_UNACKED, PolicyOperation.WRITE);
preValidation(authoritative)
.thenCompose(__ -> internalSetMaxUnackedMessagesOnSubscription(null))
@@ -1767,7 +1766,7 @@ public class PersistentTopics extends PersistentTopicsBase {
.thenCompose(__ -> internalSetDeduplication(null))
.thenRun(() -> asyncResponse.resume(Response.noContent().build()))
.exceptionally(ex -> {
- handleTopicPolicyException("setDeduplication", ex, asyncResponse);
+ handleTopicPolicyException("removeDeduplication", ex, asyncResponse);
return null;
});
}
@@ -1858,7 +1857,7 @@ public class PersistentTopics extends PersistentTopicsBase {
asyncResponse.resume(Response.noContent().build());
})
.exceptionally(ex -> {
- handleTopicPolicyException("setRetention", ex, asyncResponse);
+ handleTopicPolicyException("removeRetention", ex, asyncResponse);
return null;
});
}