[Proxy] Log warning when opening connection to broker fails
@@ -143,6 +143,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;
}
