kafka-commits mailing list archives

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

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


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

commit d83f2c342ede42f41080fb64f2df38d62894707a
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