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))
 }

Reply via email to