[pulsar] 01/02: [Proxy] Log warning when opening connection to broker fails (#14710)

[lhotari]

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

lhotari pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit b472453c02d430feff91b63b7554e044b5530d19
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Thu Mar 17 03:24:54 2022 +0200

    [Proxy] Log warning when opening connection to broker fails (#14710)
    
    (cherry picked from commit 13c45627f6ba65ae50dfdc0da105d678b382045a)
---
 .../main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java    | 2 ++
 1 file changed, 2 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 37fc3d5..44a236a 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
@@ -148,6 +148,8 @@ public class DirectProxyHandler {
         f.addListener(future -> {
             if (!future.isSuccess()) {
                 // Close the connection if the connection attempt has failed.
+                log.warn("[{}] Establishing connection to {} ({}) failed. 
Closing inbound channel.", inboundChannel,
+                        targetBrokerAddress, targetBrokerUrl, future.cause());
                 inboundChannel.close();
                 return;
             }