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 37fc3d5a8a298..44a236a8e31c6 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 @@ 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; }