kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gwens...@apache.org
Subject kafka git commit: KAFKA-2504: Stop logging WARN when client disconnects
Date Mon, 14 Sep 2015 20:14:58 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk b7d4043d8 -> d88b5bdfd


KAFKA-2504: Stop logging WARN when client disconnects

Author: jholoman <jeff.holoman@gmail.com>

Reviewers: Gwen Shapira

Closes #211 from jholoman/KAFKA-2504


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

Branch: refs/heads/trunk
Commit: d88b5bdfde0b6d020e687f6d59ad88d577910ae9
Parents: b7d4043
Author: jholoman <jeff.holoman@gmail.com>
Authored: Mon Sep 14 13:14:53 2015 -0700
Committer: Gwen Shapira <cshapi@gmail.com>
Committed: Mon Sep 14 13:14:53 2015 -0700

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/d88b5bdf/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 e1c6866..6355093 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
@@ -323,10 +323,7 @@ public class Selector implements Selectable {
                     }
                 } catch (IOException e) {
                     String desc = channel.socketDescription();
-                    if (e instanceof EOFException || e instanceof ConnectException)
-                        log.debug("Connection {} disconnected", desc);
-                    else
-                        log.warn("Error in I/O with connection to {}", desc, e);
+                    log.debug("Connection with {} disconnected", desc, e);
                     close(channel);
                     this.disconnected.add(channel.id());
                 }


Mime
View raw message