You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2022/03/24 13:42:53 UTC
[pulsar] 01/02: [Proxy] Log warning when opening connection to broker fails (#14710)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit dae653f4ae7fa21ce598e2ab720d07f8624559d8
Author: Lari Hotari <lh...@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 6e1e4d1..edf4f18 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
@@ -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;
}