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 32ec02d2f7e80..20e3f75fd8eb5 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 void deleteMaxUnackedMessagesOnSubscription(@Suspended final AsyncRespons @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 void removeDeduplication(@Suspended final AsyncResponse asyncResponse, .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 void removeRetention(@Suspended final AsyncResponse asyncResponse, asyncResponse.resume(Response.noContent().build()); }) .exceptionally(ex -> { - handleTopicPolicyException("setRetention", ex, asyncResponse); + handleTopicPolicyException("removeRetention", ex, asyncResponse); return null; }); }