[fix][client] Fix topic list watcher fail log (apache#19733)

teaey · Mar 10, 2023 · 9feb85b · 9feb85b
1 parent da30b2e
commit 9feb85b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicListWatcher.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicListWatcher.java
@@ -148,8 +148,8 @@ public void connectionOpened(ClientCnx cnx) {
                             cnx.channel().close();
                             return null;
                         }
-                        log.warn("[{}][{}] Failed to subscribe to topic on {}", topic,
-                                getHandlerName(), cnx.channel().remoteAddress());
+                        log.warn("[{}][{}] Failed to create topic list watcher on {}",
+                                topic, getHandlerName(), cnx.channel().remoteAddress());
 
                         if (e.getCause() instanceof PulsarClientException
                                 && PulsarClientException.isRetriableError(e.getCause())