(pulsar) branch master updated: [fix][proxy] Close channel on connection failure (#25770)

[zixuan]

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

nodece 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 35cf8f1fab7 [fix][proxy] Close channel on connection failure (#25770)
35cf8f1fab7 is described below

commit 35cf8f1fab754073105199269044e64de67cc732
Author: Zixuan Liu <node...@gmail.com>
AuthorDate: Thu May 14 15:21:16 2026 +0800

    [fix][proxy] Close channel on connection failure (#25770)
---
 .../main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java  | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java
 
b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java
index cf516a3da9e..b748a7aa4f7 100644
--- 
a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java
+++ 
b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java
@@ -199,6 +199,10 @@ public class DirectProxyHandler {
                         .attr("brokerHost", brokerHostAndPort)
                         .exception(future.cause())
                         .log("Establishing connection failed. Closing inbound 
channel.");
+                Channel channel = f.channel();
+                if (channel != null) {
+                    channel.close();
+                }
                 inboundChannel.close();
             }
         });