kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-1542; normal IOException in the new producer is logged as ERROR; patched by David Corley; reviewed by Jun Rao
Date Sun, 27 Jul 2014 17:55:30 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 7f2278fb9 -> fa34841d9


kafka-1542; normal IOException in the new producer is logged as ERROR; patched by David Corley;
reviewed by Jun Rao


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/fa34841d
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/fa34841d
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/fa34841d

Branch: refs/heads/trunk
Commit: fa34841d9889fc45b4824b729b71bfb2215a082d
Parents: 7f2278f
Author: David Corley <davidcorley@gmail.com>
Authored: Sun Jul 27 10:55:30 2014 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Sun Jul 27 10:55:30 2014 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/kafka/common/network/Selector.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/fa34841d/clients/src/main/java/org/apache/kafka/common/network/Selector.java
----------------------------------------------------------------------
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);
                 }
             }


Mime
View raw message