From commits-return-12214-archive-asf-public=cust-asf.ponee.io@pulsar.incubator.apache.org Thu Aug 2 01:09:44 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id DEBB6180662 for ; Thu, 2 Aug 2018 01:09:43 +0200 (CEST) Received: (qmail 46761 invoked by uid 500); 1 Aug 2018 23:09:43 -0000 Mailing-List: contact commits-help@pulsar.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@pulsar.incubator.apache.org Delivered-To: mailing list commits@pulsar.incubator.apache.org Received: (qmail 46745 invoked by uid 99); 1 Aug 2018 23:09:42 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 01 Aug 2018 23:09:42 +0000 From: GitBox To: commits@pulsar.apache.org Subject: [GitHub] sijie closed pull request #2194: Destination fix Message-ID: <153316498237.4127.16380739378107315340.gitbox@gitbox.apache.org> Date: Wed, 01 Aug 2018 23:09:42 -0000 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit sijie closed pull request #2194: Destination fix URL: https://github.com/apache/incubator-pulsar/pull/2194 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request (from a fork), the diff is supplied below (as it won't show otherwise due to GitHub magic): diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/v2/TopicLookup.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/v2/TopicLookup.java index f876518278..18b49b3a13 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/v2/TopicLookup.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/v2/TopicLookup.java @@ -37,7 +37,6 @@ import org.apache.pulsar.common.naming.TopicName; @Path("/v2/topic") -@NoSwaggerDocumentation public class TopicLookup extends TopicLookupBase { @GET diff --git a/site/docs/latest/admin-api/non-persistent-topics.md b/site/docs/latest/admin-api/non-persistent-topics.md index 59200c3112..fc0a77613e 100644 --- a/site/docs/latest/admin-api/non-persistent-topics.md +++ b/site/docs/latest/admin-api/non-persistent-topics.md @@ -141,14 +141,14 @@ $ pulsar-admin non-persistent stats \ #### REST API -{% endpoint GET /admin/v2/non-persistent/:tenant/:namespace/:destination/stats %} +{% endpoint GET /admin/v2/non-persistent/:tenant/:namespace/:topic/stats %} #### Java ```java -String destination = "non-persistent://my-tenant/my-namespace/my-topic"; -admin.nonPersistentTopics().getStats(destination); +String topic = "non-persistent://my-tenant/my-namespace/my-topic"; +admin.nonPersistentTopics().getStats(topic); ``` ### Get internal stats @@ -182,14 +182,14 @@ $ pulsar-admin non-persistent stats-internal \ #### REST API -{% endpoint GET /admin/v2/non-persistent/:tenant/:namespace/:destination/internalStats %} +{% endpoint GET /admin/v2/non-persistent/:tenant/:namespace/:topic/internalStats %} #### Java ```java -String destination = "non-persistent://my-tenant/my-namespace/my-topic"; -admin.nonPersistentTopics().getInternalStats(destination); +String topic = "non-persistent://my-tenant/my-namespace/my-topic"; +admin.nonPersistentTopics().getInternalStats(topic); ``` ### Create partitioned topic @@ -206,7 +206,7 @@ $ bin/pulsar-admin non-persistent create-partitioned-topic \ #### REST API -{% endpoint PUT /admin/v2/non-persistent/:tenant/:namespace/:destination/partitions %} +{% endpoint PUT /admin/v2/non-persistent/:tenant/:namespace/:topic/partitions %} #### Java @@ -236,7 +236,7 @@ $ pulsar-admin non-persistent get-partitioned-topic-metadata \ #### REST API -{% endpoint GET /admin/v2/non-persistent/:tenant/:namespace/:destination/partitions %} +{% endpoint GET /admin/v2/non-persistent/:tenant/:namespace/:topic/partitions %} #### Java @@ -261,13 +261,13 @@ $ pulsar-admin non-persistent unload \ #### REST API -{% endpoint PUT /admin/v2/non-persistent/:tenant/:namespace/:destination/unload %} +{% endpoint PUT /admin/v2/non-persistent/:tenant/:namespace/:topic/unload %} -[More info](../../reference/RestApi#/admin/non-persistent/:tenant/:namespace/:destination/unload) +[More info](../../reference/RestApi#/admin/non-persistent/:tenant/:namespace/:topic/unload) #### Java ```java -String destination = "non-persistent://my-tenantmy-namespace/my-topic"; -admin.nonPersistentTopics().unload(destination); +String topic = "non-persistent://my-tenant/my-namespace/my-topic"; +admin.nonPersistentTopics().unload(topic); ``` diff --git a/site/docs/latest/admin-api/persistent-topics.md b/site/docs/latest/admin-api/persistent-topics.md index 4a872da4f8..b254545f8d 100644 --- a/site/docs/latest/admin-api/persistent-topics.md +++ b/site/docs/latest/admin-api/persistent-topics.md @@ -81,10 +81,10 @@ $ pulsar-admin persistent grant-permission \ #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; +String topic = "persistent://my-tenant/my-namespace/my-topic"; String role = "test-role"; Set actions = Sets.newHashSet(AuthAction.produce, AuthAction.consume); -admin.persistentTopics().grantPermission(destination, role, actions); +admin.persistentTopics().grantPermission(topic, role, actions); ``` ### Get permission @@ -109,13 +109,13 @@ $ pulsar-admin persistent permissions \ {% endpoint GET /admin/v2/namespaces/:tenant/:namespace/permissions %} -[More info](../../reference/RestApi#/admin/namespaces/:tenant:namespace/permissions) +[More info](../../reference/RestApi#/admin/namespaces/:tenant/:namespace/permissions) #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; -admin.persistentTopics().getPermissions(destination); +String topic = "persistent://my-tenant/my-namespace/my-topic"; +admin.persistentTopics().getPermissions(topic); ``` ### Revoke permission @@ -141,16 +141,16 @@ $ pulsar-admin persistent revoke-permission \ #### REST API -{% endpoint DELETE /admin/v2/namespaces/:tenant:namespace/permissions/:role %} +{% endpoint DELETE /admin/v2/namespaces/:tenant/:namespace/permissions/:role %} [More info](../../reference/RestApi#/admin/namespaces/:tenant/:namespace/permissions/:role) #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; +String topic = "persistent://my-tenant/my-namespace/my-topic"; String role = "test-role"; -admin.persistentTopics().revokePermissions(destination, role); +admin.persistentTopics().revokePermissions(topic, role); ``` ### Delete topic @@ -168,15 +168,15 @@ $ pulsar-admin persistent delete \ #### REST API -{% endpoint DELETE /admin/v2/persistent/:tenant/:namespace/:destination %} +{% endpoint DELETE /admin/v2/persistent/:tenant/:namespace/:topic %} -[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:destination) +[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:topic) #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; -admin.persistentTopics().delete(destination); +String topic = "persistent://my-tenant/my-namespace/my-topic"; +admin.persistentTopics().delete(topic); ``` ### Unload topic @@ -194,15 +194,15 @@ $ pulsar-admin persistent unload \ #### REST API -{% endpoint PUT /admin/v2/persistent/:tenant/:namespace/:destination/unload %} +{% endpoint PUT /admin/v2/persistent/:tenant/:namespace/:topic/unload %} -[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:destination/unload) +[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:topic/unload) #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; -admin.persistentTopics().unload(destination); +String topic = "persistent://my-tenant/my-namespace/my-topic"; +admin.persistentTopics().unload(topic); ``` ### Get stats @@ -305,15 +305,15 @@ $ pulsar-admin persistent stats \ #### REST API -{% endpoint GET /admin/v2/persistent/:tenant/:namespace/:destination/stats %} +{% endpoint GET /admin/v2/persistent/:tenant/:namespace/:topic/stats %} -[More info](../../reference/RestApi#/admin/persistent/:tenant:namespace/:destination/stats) +[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:topic/stats) #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; -admin.persistentTopics().getStats(destination); +String topic = "persistent://my-tenant/my-namespace/my-topic"; +admin.persistentTopics().getStats(topic); ``` ### Get internal stats @@ -415,15 +415,15 @@ $ pulsar-admin persistent stats-internal \ #### REST API -{% endpoint GET /admin/v2/persistent/:tenant/:namespace/:destination/internalStats %} +{% endpoint GET /admin/v2/persistent/:tenant/:namespace/:topic/internalStats %} -[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:destination/internalStats) +[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:topic/internalStats) #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; -admin.persistentTopics().getInternalStats(destination); +String topic = "persistent://my-tenant/my-namespace/my-topic"; +admin.persistentTopics().getInternalStats(topic); ``` ### Peek messages @@ -445,17 +445,17 @@ msg-payload #### REST API -{% endpoint GET /admin/v2/persistent/:tenant/:namespace/:destination/subscription/:subName/position/:messagePosition %} +{% endpoint GET /admin/v2/persistent/:tenant/:namespace/:topic/subscription/:subName/position/:messagePosition %} -[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:destination/subscription/:subName/position/:messagePosition) +[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:topic/subscription/:subName/position/:messagePosition) #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; +String topic = "persistent://my-tenant/my-namespace/my-topic"; String subName = "my-subscription"; int numMessages = 1; -admin.persistentTopics().peekMessages(destination, subName, numMessages); +admin.persistentTopics().peekMessages(topic, subName, numMessages); ``` ### Skip messages @@ -473,17 +473,17 @@ $ pulsar-admin persistent skip \ #### REST API -{% endpoint POST /admin/v2/persistent/:tenant/:namespace/:destination/subscription/:subName/skip/:numMessages %} +{% endpoint POST /admin/v2/persistent/:tenant/:namespace/:topic/subscription/:subName/skip/:numMessages %} -[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:destination/subscription/:subName/skip/:numMessages) +[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:topic/subscription/:subName/skip/:numMessages) #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; +String topic = "persistent://my-tenant/my-namespace/my-topic"; String subName = "my-subscription"; int numMessages = 1; -admin.persistentTopics().skipMessages(destination, subName, numMessages); +admin.persistentTopics().skipMessages(topic, subName, numMessages); ``` ### Skip all messages @@ -501,16 +501,16 @@ $ pulsar-admin persistent skip-all \ #### REST API -{% endpoint POST /admin/v2/persistent/:tenant/:namespace/:destination/subscription/:subName/skip_all %} +{% endpoint POST /admin/v2/persistent/:tenant/:namespace/:topic/subscription/:subName/skip_all %} -[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:destination/subscription/:subName/skip_all) +[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:topic/subscription/:subName/skip_all) #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; +String topic = "persistent://my-tenant/my-namespace/my-topic"; String subName = "my-subscription"; -admin.persistentTopics().skipAllMessages(destination, subName); +admin.persistentTopics().skipAllMessages(topic, subName); ``` ### Reset cursor @@ -528,22 +528,22 @@ $ pulsar-admin persistent reset-cursor \ #### REST API -{% endpoint POST /admin/v2/persistent/:tenant/:namespace/:destination/subscription/:subName/resetcursor/:timestamp %} +{% endpoint POST /admin/v2/persistent/:tenant/:namespace/:topic/subscription/:subName/resetcursor/:timestamp %} -[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:destination/subscription/:subName/resetcursor/:timestamp) +[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:topic/subscription/:subName/resetcursor/:timestamp) #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; +String topic = "persistent://my-tenant/my-namespace/my-topic"; String subName = "my-subscription"; long timestamp = 2342343L; -admin.persistentTopics().skipAllMessages(destination, subName, timestamp); +admin.persistentTopics().skipAllMessages(topic, subName, timestamp); ``` -### Lookup of topic +### Lookup topic -It locates broker url which is serving the given topic. +It locates the broker url which is serving the given topic. #### pulsar-admin @@ -557,13 +557,13 @@ $ pulsar-admin persistent lookup \ #### REST API -{% endpoint GET /lookup/v2/destination/persistent/:tenant:namespace/:destination %} +{% endpoint GET /lookup/v2/topic/persistent/:tenant/:namespace/:topic %} #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; -admin.lookup().lookupDestination(destination); +String topic = "persistent://my-tenant/my-namespace/my-topic"; +admin.lookup().lookupTopic(topic); ``` ### Get bundle @@ -582,13 +582,13 @@ $ pulsar-admin persistent bundle-range \ #### REST API -{% endpoint GET /lookup/v2/destination/:destination_domain/:tenant/:namespace/:destination/bundle %} +{% endpoint GET /lookup/v2/topic/:topic_domain/:tenant/:namespace/:topic/bundle %} #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; -admin.lookup().getBundleRange(destination); +String topic = "persistent://my-tenant/my-namespace/my-topic"; +admin.lookup().getBundleRange(topic); ``` @@ -607,15 +607,15 @@ $ pulsar-admin persistent subscriptions \ #### REST API -{% endpoint GET /admin/v2/persistent/:tenant/:namespace/:destination/subscriptions %} +{% endpoint GET /admin/v2/persistent/:tenant/:namespace/:topic/subscriptions %} -[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:destination/subscriptions) +[More info](../../reference/RestApi#/admin/persistent/:tenant/:namespace/:topic/subscriptions) #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; -admin.persistentTopics().getSubscriptions(destination); +String topic = "persistent://my-tenant/my-namespace/my-topic"; +admin.persistentTopics().getSubscriptions(topic); ``` ### Unsubscribe @@ -640,7 +640,7 @@ $ pulsar-admin persistent unsubscribe \ #### Java ```java -String destination = "persistent://my-tenant/my-namespace/my-topic"; +String topic = "persistent://my-tenant/my-namespace/my-topic"; String subscriptionName = "my-subscription"; -admin.persistentTopics().deleteSubscription(destination, subscriptionName); +admin.persistentTopics().deleteSubscription(topic, subscriptionName); ``` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: users@infra.apache.org With regards, Apache Git Services