Repository: kafka Updated Branches: refs/heads/trunk 427e63851 -> fa3254544
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 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/fa325454 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/fa325454 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/fa325454 Branch: refs/heads/trunk Commit: fa32545442ef6724aa9fb5f4e0e269b0c873288f Parents: 427e638 Author: Ryan Pridgeon <[email protected]> Authored: Fri Jul 22 18:09:38 2016 +0100 Committer: Ismael Juma <[email protected]> Committed: Fri Jul 22 18:09:38 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/fa325454/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 ad9ac8d..fcf0bc5 100644 --- a/core/src/main/scala/kafka/network/SocketServer.scala +++ b/core/src/main/scala/kafka/network/SocketServer.scala @@ -332,8 +332,8 @@ private[kafka] class Acceptor(val endPoint: EndPoint, if (sendBufferSize != Selectable.USE_DEFAULT_BUFFER_SIZE) 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))
