This is an automated email from the ASF dual-hosted git repository.
rdhabalia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 5d73bb4 Fix: destination lookup url for v2 (#2075)
5d73bb4 is described below
commit 5d73bb40f1ade12ba27d49d26cb50477f4e39c30
Author: Rajan Dhabalia <[email protected]>
AuthorDate: Tue Jul 3 11:00:07 2018 -0700
Fix: destination lookup url for v2 (#2075)
---
.../src/main/java/org/apache/pulsar/client/impl/HttpLookupService.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/HttpLookupService.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/HttpLookupService.java
index a5b0455..185412c 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/HttpLookupService.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/HttpLookupService.java
@@ -100,7 +100,7 @@ class HttpLookupService implements LookupService {
public CompletableFuture<List<String>>
getTopicsUnderNamespace(NamespaceName namespace) {
CompletableFuture<List<String>> future = new CompletableFuture<>();
- String format = namespace.isV2() ?
"admin/v2/namespaces/%s/destinations" : "admin/namespaces/%s/destinations";
+ String format = namespace.isV2() ? "admin/v2/namespaces/%s/topics" :
"admin/namespaces/%s/destinations";
httpClient
.get(String.format(format, namespace), String[].class)
.thenAccept(topics -> {