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 2021/09/28 14:31:44 UTC
[pulsar-client-go] branch master updated: fix
TestNamespaceTopicsNamespaceDoesNotExit (#625)
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-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new b0f328e fix TestNamespaceTopicsNamespaceDoesNotExit (#625)
b0f328e is described below
commit b0f328e358d45e822efac164b11dc493bbecfcaa
Author: Rui Fu <fr...@users.noreply.github.com>
AuthorDate: Tue Sep 28 22:31:38 2021 +0800
fix TestNamespaceTopicsNamespaceDoesNotExit (#625)
fix TestNamespaceTopicsNamespaceDoesNotExit error after pulsar release 2.8.1
ref: apache/pulsar#11172
---
pulsar/client_impl_test.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/pulsar/client_impl_test.go b/pulsar/client_impl_test.go
index b1d128a..e9e94af 100644
--- a/pulsar/client_impl_test.go
+++ b/pulsar/client_impl_test.go
@@ -383,7 +383,7 @@ func TestNamespaceTopicsNamespaceDoesNotExit(t *testing.T) {
// fetch from namespace that does not exist
name := generateRandomName()
- topics, err := ci.lookupService.GetTopicsOfNamespace(fmt.Sprintf("%s/%s", name, name), internal.Persistent)
+ topics, err := ci.lookupService.GetTopicsOfNamespace(fmt.Sprintf("public/%s", name), internal.Persistent)
assert.Nil(t, err)
assert.Equal(t, 0, len(topics))
}
@@ -401,7 +401,7 @@ func TestNamespaceTopicsNamespaceDoesNotExitWebURL(t *testing.T) {
// fetch from namespace that does not exist
name := generateRandomName()
- topics, err := ci.lookupService.GetTopicsOfNamespace(fmt.Sprintf("%s/%s", name, name), internal.Persistent)
+ topics, err := ci.lookupService.GetTopicsOfNamespace(fmt.Sprintf("public/%s", name), internal.Persistent)
assert.NotNil(t, err)
assert.Equal(t, 0, len(topics))
}