(pulsar) branch master updated: [fix][client] Fix idle connection release ignoring V5 watch sessions (#25697)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari 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 0a6b6f90bb6 [fix][client] Fix idle connection release ignoring V5 
watch sessions (#25697)
0a6b6f90bb6 is described below

commit 0a6b6f90bb68d1df426fc301c609c1d4751fe159
Author: Dream95 <zhou_8...@163.com>
AuthorDate: Wed May 6 23:00:24 2026 +0800

    [fix][client] Fix idle connection release ignoring V5 watch sessions 
(#25697)
    
    Signed-off-by: Dream95 <zhou_8...@163.com>
---
 .../src/main/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 40c4e12aa05..8b5623b4bb7 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 class ClientCnx extends PulsarHandler {
         if (!topicListWatchers.isEmpty()) {
             return false;
         }
+        if (!dagWatchSessions.isEmpty()) {
+            return false;
+        }
+        if (!scalableConsumerSessions.isEmpty()) {
+            return false;
+        }
+        if (!scalableTopicsWatchers.isEmpty()) {
+            return false;
+        }
         return true;
     }
 }