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 <freez...@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)) }