Log curator state changes SUSPENDED, RECONNECTED and LOST

1 files changed, 8 insertions, 1 deletions

diff --git a/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java b/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java
index d6be27a0919..d1246699ebc 100644
--- a/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java
+++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java
@@ -34,6 +34,7 @@ import java.util.List;
 import java.util.Optional;
 import java.util.concurrent.ExecutorService;
 import java.util.function.Function;
+import java.util.logging.Logger;
 
 /**
  * Curator interface for Vespa.
@@ -47,6 +48,8 @@ import java.util.function.Function;
  */
 public class Curator implements AutoCloseable {
 
+    private static final Logger logger = Logger.getLogger(Curator.class.getName());
+
     private static final int ZK_SESSION_TIMEOUT = 30000;
     private static final int ZK_CONNECTION_TIMEOUT = 30000;
 
@@ -201,7 +204,11 @@ public class Curator implements AutoCloseable {
     // To avoid getting warning in log, see ticket 6389740
     private void addFakeListener() {
         curatorFramework.getConnectionStateListenable().addListener((curatorFramework, connectionState) -> {
-            // empty, not needed now
+            switch (connectionState) {
+                case SUSPENDED: logger.info("ZK connection state change: SUSPENDED"); break;
+                case RECONNECTED: logger.info("ZK connection state change: RECONNECTED"); break;
+                case LOST: logger.warning("ZK connection state change: LOST"); break;
+            }
         });
     }