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 e1c686630ca52..6355093bb001a 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 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()); }