KAFKA-2504: Stop logging WARN when client disconnects

Author: jholoman <[email protected]> Reviewers: Gwen Shapira Closes apache#211 from jholoman/KAFKA-2504
alexissellier · Sep 14, 2015 · d88b5bd · d88b5bd
1 parent b7d4043
commit d88b5bd
Showing 1 changed file with 1 addition and 4 deletions.
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
@@ -323,10 +323,7 @@ public void poll(long timeout) throws IOException {
                     }
                 } 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());
                 }