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 <[email protected]> Reviewers: Ismael Juma <[email protected]> Closes #1648 from rnpridgeon/trunk (cherry picked from commit fa32545442ef6724aa9fb5f4e0e269b0c873288f) Signed-off-by: Ismael Juma <[email protected]> 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 <[email protected]> Authored: Fri Jul 22 18:09:38 2016 +0100 Committer: Ismael Juma <[email protected]> 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))
