[pulsar] branch master updated: [improve][broker] log sessionId with zk-session-watcher for debugging (#18291)

[rdhabalia]

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/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 987e0dacd31 [improve][broker] log sessionId with zk-session-watcher 
for debugging (#18291)
987e0dacd31 is described below

commit 987e0dacd31aeaba6a2f1a59ec5c55fb59bb7999
Author: Rajan Dhabalia <rdhaba...@apache.org>
AuthorDate: Tue Nov 1 16:23:17 2022 -0700

    [improve][broker] log sessionId with zk-session-watcher for debugging 
(#18291)
---
 .../main/java/org/apache/pulsar/metadata/impl/ZKSessionWatcher.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKSessionWatcher.java
 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKSessionWatcher.java
index 38d0ba32a36..a0247e22319 100644
--- 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKSessionWatcher.java
+++ 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKSessionWatcher.java
@@ -149,8 +149,8 @@ public class ZKSessionWatcher implements AutoCloseable, 
Watcher {
                 currentStatus = SessionEvent.SessionLost;
                 sessionListener.accept(currentStatus);
             } else if (currentStatus != SessionEvent.SessionLost) {
-                log.warn("ZooKeeper client is disconnected. Waiting to 
reconnect, time remaining = {} seconds",
-                        timeRemainingMillis / 1000.0);
+                log.warn("[{}] ZooKeeper client is disconnected. Waiting to 
reconnect, time remaining = {} seconds",
+                        zk.getSessionId(), timeRemainingMillis / 1000.0);
                 if (currentStatus == SessionEvent.SessionReestablished) {
                     currentStatus = SessionEvent.ConnectionLost;
                     sessionListener.accept(currentStatus);