From 785181e2df591ca8bbc497153e126de2fa2653f1 Mon Sep 17 00:00:00 2001 From: David Corley Date: Fri, 25 Jul 2014 08:02:24 +0100 Subject: [PATCH 1/1] KAFKA-1542 Log normal IOException in new producer as WARN and add remote host information --- clients/src/main/java/org/apache/kafka/common/network/Selector.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/common/network/Selector.java b/clients/src/main/java/org/apache/kafka/common/network/Selector.java index 93f2f1c..45e57b4 100644 --- a/clients/src/main/java/org/apache/kafka/common/network/Selector.java +++ b/clients/src/main/java/org/apache/kafka/common/network/Selector.java @@ -262,7 +262,7 @@ public class Selector implements Selectable { if (!key.isValid()) close(key); } catch (IOException e) { - log.error("Error in I/O: ", e); + log.warn("Error in I/O with {}",channel.socket().getInetAddress().getHostAddress() , e); close(key); } } -- 1.8.5.2 (Apple Git-48)