From 9b375c26cf22422daa434824528d210fcc3bda56 Mon Sep 17 00:00:00 2001 From: Like Date: Thu, 12 Sep 2019 12:01:20 +0800 Subject: [PATCH] Fix method comment for class Topics (#5106) --- .../org/apache/pulsar/client/admin/Topics.java | 15 ++++++--------- 1 file changed, 6 insertions(+), 9 deletions(-) diff --git a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Topics.java b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Topics.java index bc705c70d27a9..4bb0ab4393e0f 100644 --- a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Topics.java +++ b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Topics.java @@ -174,12 +174,9 @@ List getListInBundle(String namespace, String bundleRange) * Topic url * @param role * Client role to which remove permission - * @throws UniformInterfaceException - * if the operations was not successful - * * @throws NotAuthorizedException * Don't have admin permission - * @throws NotFound + * @throws NotFoundException * Namespace does not exist * @throws PreconditionFailedException * Permissions are not set at the topic level @@ -517,7 +514,7 @@ List getListInBundle(String namespace, String bundleRange) * "msgRateIn" : 100.0, * "msgThroughputIn" : 10240.0, * "msgRateOut" : 100.0, - * "msghroughputOut" : 10240.0, + * "msgThroughputOut" : 10240.0, * "replicationBacklog" : 0, * "connected" : true, * } @@ -698,7 +695,7 @@ List getListInBundle(String namespace, String bundleRange) * Get the stats for the partitioned topic * * @param topic - * @param perPartition + * topic name * @return * @throws PulsarAdminException */ @@ -822,7 +819,7 @@ PartitionedTopicInternalStats getPartitionedInternalStats(String topic) * * @param topic * topic name - * @param subName + * @param subscriptionName * Subscription name * @param expireTimeInSeconds * Expire messages older than time in seconds @@ -837,7 +834,7 @@ void expireMessages(String topic, String subscriptionName, long expireTimeInSeco * * @param topic * topic name - * @param subName + * @param subscriptionName * Subscription name * @param expireTimeInSeconds * Expire messages older than time in seconds @@ -1000,7 +997,7 @@ void createSubscription(String topic, String subscriptionName, MessageId message * topic name * @param subName * Subscription name - * @param MessageId + * @param messageId * reset subscription to messageId (or previous nearest messageId if given messageId is not valid) */ CompletableFuture resetCursorAsync(String topic, String subName, MessageId messageId);