From a9f34692c100bf6fcc0fe70c4a5295a9548e59ae Mon Sep 17 00:00:00 2001 From: Dream95 Date: Wed, 6 May 2026 19:26:00 +0800 Subject: [PATCH] [fix][client] Fix idle connection release ignoring V5 watch sessions Signed-off-by: Dream95 --- .../java/org/apache/pulsar/client/impl/ClientCnx.java | 9 +++++++++ 1 file changed, 9 insertions(+) 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; } }