Browse Source

KAFKA-2504: Stop logging WARN when client disconnects

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

Reviewers: Gwen Shapira

Closes #211 from jholoman/KAFKA-2504
pull/211/merge
jholoman 9 years ago committed by Gwen Shapira
parent
commit
d88b5bdfde
  1. 5
      clients/src/main/java/org/apache/kafka/common/network/Selector.java

5
clients/src/main/java/org/apache/kafka/common/network/Selector.java

@ -323,10 +323,7 @@ public class Selector implements Selectable { @@ -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());
}

Loading…
Cancel
Save