This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d631d2c3e58af42cc940924b4b6c3b5ac9102997 Author: Zixuan Liu <[email protected]> AuthorDate: Thu May 14 15:21:16 2026 +0800 [fix][proxy] Close channel on connection failure (#25770) (cherry picked from commit 35cf8f1fab754073105199269044e64de67cc732) --- .../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 f707abbc06a..773cbc5fbcd 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 @@ -194,6 +194,10 @@ public class DirectProxyHandler { // Close the connection if the connection attempt has failed. log.warn("[{}] Establishing connection to {} ({}) failed. Closing inbound channel.", inboundChannel, targetBrokerAddress, brokerHostAndPort, future.cause()); + Channel channel = f.channel(); + if (channel != null) { + channel.close(); + } inboundChannel.close(); } });
