You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2015/06/17 00:38:04 UTC
[2/2] kafka git commit: kafka-2252;
Socket connection closing is logged, but not corresponding opening of
socket; patched by Gwen Shapira; reviewed by Jun Rao
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 <cs...@gmail.com>
Authored: Tue Jun 16 15:37:58 2015 -0700
Committer: Jun Rao <ju...@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);