diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java index 40c4e12aa0533..8b5623b4bb77e 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java @@ -1748,6 +1748,15 @@ public boolean idleCheck() { if (!topicListWatchers.isEmpty()) { return false; } + if (!dagWatchSessions.isEmpty()) { + return false; + } + if (!scalableConsumerSessions.isEmpty()) { + return false; + } + if (!scalableTopicsWatchers.isEmpty()) { + return false; + } return true; } }