From d4b7243a24d75af5b809c6cd62549b1f5fd3b57c Mon Sep 17 00:00:00 2001 From: jholoman Date: Sun, 13 Sep 2015 00:15:56 -0400 Subject: [PATCH 1/3] KAFKA-2504 --- .../src/main/java/org/apache/kafka/common/network/Selector.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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..0db4549ff0468 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 @@ -326,7 +326,7 @@ public void poll(long timeout) throws IOException { 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("Error in I/O with connection to {}", desc, e); close(channel); this.disconnected.add(channel.id()); } From 881f7f478908d31c92a0a144850dc045f7718100 Mon Sep 17 00:00:00 2001 From: jholoman Date: Mon, 14 Sep 2015 10:28:45 -0400 Subject: [PATCH 2/3] 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 0db4549ff0468..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.debug("Error in I/O with connection to {}", desc, e); + log.debug("Connection with {} disconnected", desc, e); close(channel); this.disconnected.add(channel.id()); } From 68510e20454a5cda93a90d620a0ce05ffd7b73a8 Mon Sep 17 00:00:00 2001 From: jholoman Date: Mon, 14 Sep 2015 17:51:42 -0400 Subject: [PATCH 3/3] KAFKA-2504 fixed broken imports --- .../src/main/java/org/apache/kafka/common/network/Selector.java | 2 -- 1 file changed, 2 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 6355093bb001a..5a4909e4e5afe 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 @@ -12,9 +12,7 @@ */ package org.apache.kafka.common.network; -import java.io.EOFException; import java.io.IOException; -import java.net.ConnectException; import java.net.InetSocketAddress; import java.net.Socket; import java.nio.channels.*;