kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-3983; Add additional information to Acceptor debug message
Date Fri, 22 Jul 2016 17:10:15 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.0 71a598a17 -> 24daae7d2


KAFKA-3983; Add additional information to Acceptor debug message

Add additional information to Acceptor debug message upon connection acceptance

Author: rnpridgeon <ryan.n.pridgeon@gmail.com>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #1648 from rnpridgeon/trunk

(cherry picked from commit fa32545442ef6724aa9fb5f4e0e269b0c873288f)
Signed-off-by: Ismael Juma <ismael@juma.me.uk>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/24daae7d
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/24daae7d
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/24daae7d

Branch: refs/heads/0.10.0
Commit: 24daae7d2703adffcbc90ab903916fa39601ce32
Parents: 71a598a
Author: Ryan Pridgeon <ryan.n.pridgeon@gmail.com>
Authored: Fri Jul 22 18:09:38 2016 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Fri Jul 22 18:10:09 2016 +0100

----------------------------------------------------------------------
 core/src/main/scala/kafka/network/SocketServer.scala | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/24daae7d/core/src/main/scala/kafka/network/SocketServer.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala
index b757abd..ff2231c 100644
--- a/core/src/main/scala/kafka/network/SocketServer.scala
+++ b/core/src/main/scala/kafka/network/SocketServer.scala
@@ -328,8 +328,8 @@ private[kafka] class Acceptor(val endPoint: EndPoint,
       socketChannel.socket().setKeepAlive(true)
       socketChannel.socket().setSendBufferSize(sendBufferSize)
 
-      debug("Accepted connection from %s on %s. sendBufferSize [actual|requested]: [%d|%d]
recvBufferSize [actual|requested]: [%d|%d]"
-            .format(socketChannel.socket.getInetAddress, socketChannel.socket.getLocalSocketAddress,
+      debug("Accepted connection from %s on %s and assigned it to processor %d, sendBufferSize
[actual|requested]: [%d|%d] recvBufferSize [actual|requested]: [%d|%d]"
+            .format(socketChannel.socket.getRemoteSocketAddress, socketChannel.socket.getLocalSocketAddress,
processor.id,
                   socketChannel.socket.getSendBufferSize, sendBufferSize,
                   socketChannel.socket.getReceiveBufferSize, recvBufferSize))
 


Mime
View raw message