From d88b5bdfde0b6d020e687f6d59ad88d577910ae9 Mon Sep 17 00:00:00 2001 From: jholoman Date: Mon, 14 Sep 2015 13:14:53 -0700 Subject: [PATCH] KAFKA-2504: Stop logging WARN when client disconnects Author: jholoman Reviewers: Gwen Shapira Closes #211 from jholoman/KAFKA-2504 --- .../main/java/org/apache/kafka/common/network/Selector.java | 5 +---- 1 file changed, 1 insertion(+), 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 index e1c686630ca..6355093bb00 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()); }