[Proxy] Log warning when opening connection to broker fails (apache#1…

…4710)
Nicklee007 · Apr 20, 2022 · 4dc3986 · 4dc3986
1 parent c4c16ec
commit 4dc3986
Showing 1 changed file with 2 additions and 0 deletions.
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
@@ -143,6 +143,8 @@ protected void initChannel(SocketChannel ch) {
         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;
             }