You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rx...@apache.org on 2020/05/12 04:11:06 UTC
[pulsar] branch master updated: [Docs] Fix the Create subscribtion
swagger of PersistentTopic (#6776)
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new ce29135 [Docs] Fix the Create subscribtion swagger of PersistentTopic (#6776)
ce29135 is described below
commit ce29135cfa15d9f20477a137c497848320f1b737
Author: 冉小龙 <rx...@apache.org>
AuthorDate: Tue May 12 12:10:50 2020 +0800
[Docs] Fix the Create subscribtion swagger of PersistentTopic (#6776)
* [Docs] Fix the Create subscribtion swagger of PersistentTopic
Signed-off-by: xiaolong.ran <rx...@apache.org>
* fix a little
Signed-off-by: xiaolong.ran <rx...@apache.org>
* fix a little
Signed-off-by: xiaolong.ran <rx...@apache.org>
* fix comments
Signed-off-by: xiaolong.ran <rx...@apache.org>
* fix comments
Signed-off-by: xiaolong.ran <rx...@apache.org>
* fix comments
Signed-off-by: xiaolong.ran <rx...@apache.org>
---
.../org/apache/pulsar/broker/admin/v1/PersistentTopics.java | 2 +-
.../org/apache/pulsar/broker/admin/v2/PersistentTopics.java | 13 ++++++++-----
2 files changed, 9 insertions(+), 6 deletions(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java
index 31367cc..3c56f1c 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java
@@ -512,7 +512,7 @@ public class PersistentTopics extends PersistentTopicsBase {
@PUT
@Path("/{property}/{cluster}/{namespace}/{topic}/subscription/{subscriptionName}")
- @ApiOperation(value = "Reset subscription to message position closest to given position.", notes = "Creates a subscription on the topic at the specified message id")
+ @ApiOperation(value = "Create a subscription on the topic.", notes = "Creates a subscription on the topic at the specified message id")
@ApiResponses(value = {
@ApiResponse(code = 307, message = "Current broker doesn't serve the namespace of this topic"),
@ApiResponse(code = 403, message = "Don't have admin permission"),
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 789b7ef..dcd2ed8 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
@@ -778,7 +778,7 @@ public class PersistentTopics extends PersistentTopicsBase {
@PUT
@Path("/{tenant}/{namespace}/{topic}/subscription/{subscriptionName}")
- @ApiOperation(value = "Reset subscription to message position closest to given position.", notes = "Creates a subscription on the topic at the specified message id")
+ @ApiOperation(value = "Create a subscription on the topic.", notes = "Creates a subscription on the topic at the specified message id")
@ApiResponses(value = {
@ApiResponse(code = 307, message = "Current broker doesn't serve the namespace of this topic"),
@ApiResponse(code = 401, message = "Don't have permission to administrate resources on this tenant or" +
@@ -798,14 +798,17 @@ public class PersistentTopics extends PersistentTopicsBase {
@PathParam("topic") @Encoded String topic,
@ApiParam(value = "Subscription to create position on", required = true)
@PathParam("subscriptionName") String encodedSubName,
- @ApiParam(value = "messageId where to create the subscription. " +
+ @ApiParam(value = "Is authentication required to perform this operation")
+ @QueryParam("authoritative") @DefaultValue("false") boolean authoritative,
+ @ApiParam(name = "messageId", value = "messageId where to create the subscription. " +
"It can be 'latest', 'earliest' or (ledgerId:entryId)",
defaultValue = "latest",
allowableValues = "latest,earliest,ledgerId:entryId"
)
- @QueryParam("authoritative") @DefaultValue("false") boolean authoritative, MessageIdImpl messageId,
- @ApiParam(value = "Is authentication required to perform this operation")
- @QueryParam("replicated") boolean replicated) {
+ MessageIdImpl messageId,
+ @ApiParam(value = "Is replicated required to perform this operation")
+ @QueryParam("replicated") boolean replicated
+ ) {
try {
validateTopicName(tenant, namespace, topic);
internalCreateSubscription(asyncResponse, decode(encodedSubName), messageId, authoritative, replicated);