kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rsiva...@apache.org
Subject [kafka] branch trunk updated: KAFKA-7111: Log error connecting to node at a higher log level (#5312)
Date Fri, 29 Jun 2018 14:37:19 GMT
This is an automated email from the ASF dual-hosted git repository.

rsivaram pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 053d831  KAFKA-7111: Log error connecting to node at a higher log level (#5312)
053d831 is described below

commit 053d831992e5351deb174f11f0ecd0ebe7c4ba5a
Author: Stanislav Kozlovski <familyguyuser192@windowslive.com>
AuthorDate: Fri Jun 29 15:37:14 2018 +0100

    KAFKA-7111: Log error connecting to node at a higher log level (#5312)
    
    There are cases where the broker would return an unresolve-able address (e.g broker inside
a docker network while client is outside) and the client would not log any information as
to why it is timing out, since the default log level does not print DEBUG messages.
    
    Changing this log level will enable easier troubleshooting in such circumstances. This
change does not change the logs shown on transient failures like a broker failure.
---
 clients/src/main/java/org/apache/kafka/clients/NetworkClient.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
index ea16ac9..720a781 100644
--- a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
+++ b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
@@ -869,7 +869,7 @@ public class NetworkClient implements KafkaClient {
             connectionStates.disconnected(nodeConnectionId, now);
             /* maybe the problem is our metadata, update it */
             metadataUpdater.requestUpdate();
-            log.debug("Error connecting to node {}", node, e);
+            log.warn("Error connecting to node {}", node, e);
         }
     }
 


Mime
View raw message