kafka-2252; Socket connection closing is logged, but not corresponding opening of socket; patched by Gwen Shapira; reviewed by Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/47850563 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/47850563 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/47850563 Branch: refs/heads/trunk Commit: 478505632edc8f4b51e4ed561d1adf455256c3e4 Parents: 7009f1d Author: Gwen Shapira <csh...@gmail.com> Authored: Tue Jun 16 15:37:58 2015 -0700 Committer: Jun Rao <jun...@gmail.com> Committed: Tue Jun 16 15:37:58 2015 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/kafka/common/network/Selector.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/47850563/clients/src/main/java/org/apache/kafka/common/network/Selector.java ---------------------------------------------------------------------- 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 1da215b..4aee214 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 @@ -267,6 +267,7 @@ public class Selector implements Selectable { key.interestOps(key.interestOps() & ~SelectionKey.OP_CONNECT | SelectionKey.OP_READ); this.connected.add(transmissions.id); this.sensors.connectionCreated.record(); + log.debug("Connection {} created", transmissions.id); } /* read from any connections that have readable data */ @@ -307,7 +308,7 @@ public class Selector implements Selectable { } catch (IOException e) { String desc = socketDescription(channel); if (e instanceof EOFException || e instanceof ConnectException) - log.info("Connection {} disconnected", desc); + log.debug("Connection {} disconnected", desc); else log.warn("Error in I/O with connection to {}", desc, e); close(transmissions.id);