kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject kafka git commit: KAFKA-5405; Request log should log throttle time
Date Mon, 12 Jun 2017 04:34:44 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.11.0 50b20d2d3 -> 4508fb2e4


KAFKA-5405; Request log should log throttle time

Record `apiThrottleTime` in RequestChannel.
junrao  A trivial change. Please review. Thanks.

Author: huxihx <huxi_2b@hotmail.com>

Reviewers: Jun Rao <junrao@gmail.com>

Closes #3265 from huxihx/KAFKA-5405

(cherry picked from commit a623d8fe391f4c4439707b4522c66a3764f620d8)
Signed-off-by: Jun Rao <junrao@gmail.com>


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

Branch: refs/heads/0.11.0
Commit: 4508fb2e488cb44647cb8da03b17e2e8e9a07e62
Parents: 50b20d2
Author: huxihx <huxi_2b@hotmail.com>
Authored: Sun Jun 11 21:34:29 2017 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Sun Jun 11 21:34:40 2017 -0700

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/4508fb2e/core/src/main/scala/kafka/network/RequestChannel.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/network/RequestChannel.scala b/core/src/main/scala/kafka/network/RequestChannel.scala
index bb19346..aff1526 100644
--- a/core/src/main/scala/kafka/network/RequestChannel.scala
+++ b/core/src/main/scala/kafka/network/RequestChannel.scala
@@ -189,8 +189,8 @@ object RequestChannel extends Logging {
         val apiRemoteTimeMs = nanosToMs(apiRemoteCompleteTimeNanos - apiLocalCompleteTimeNanos)
         val responseQueueTimeMs = nanosToMs(responseDequeueTimeNanos - responseCompleteTimeNanos)
         val responseSendTimeMs = nanosToMs(endTimeNanos - responseDequeueTimeNanos)
-        requestLogger.trace("Completed request:%s from connection %s;totalTime:%f,requestQueueTime:%f,localTime:%f,remoteTime:%f,responseQueueTime:%f,sendTime:%f,securityProtocol:%s,principal:%s,listener:%s"
-          .format(requestDesc(detailsEnabled), connectionId, totalTimeMs, requestQueueTimeMs,
apiLocalTimeMs, apiRemoteTimeMs, responseQueueTimeMs, responseSendTimeMs, securityProtocol,
session.principal, listenerName.value))
+        requestLogger.trace("Completed request:%s from connection %s;totalTime:%f,requestQueueTime:%f,localTime:%f,remoteTime:%f,throttleTime:%f,responseQueueTime:%f,sendTime:%f,securityProtocol:%s,principal:%s,listener:%s"
+          .format(requestDesc(detailsEnabled), connectionId, totalTimeMs, requestQueueTimeMs,
apiLocalTimeMs, apiRemoteTimeMs, apiThrottleTime, responseQueueTimeMs, responseSendTimeMs,
securityProtocol, session.principal, listenerName.value))
       }
     }
   }


Mime
View raw message