kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gwens...@apache.org
Subject kafka git commit: MINOR: Fix trace/debug logs in RequestChannel
Date Thu, 03 Sep 2015 20:25:32 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 24da54272 -> 4ffbfefcc


MINOR: Fix trace/debug logs in RequestChannel

Author: Ashish Singh <asingh@cloudera.com>

Reviewers: Ismael Juma, Gwen Shapira

Closes #192 from SinghAsDev/KAFKA-2461-2


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

Branch: refs/heads/trunk
Commit: 4ffbfefccbbbc513e708bdacbf2ff32772b5c85f
Parents: 24da542
Author: Ashish Singh <asingh@cloudera.com>
Authored: Thu Sep 3 13:25:16 2015 -0700
Committer: Gwen Shapira <cshapi@gmail.com>
Committed: Thu Sep 3 13:25:16 2015 -0700

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/4ffbfefc/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 5067d1d..5d09a16 100644
--- a/core/src/main/scala/kafka/network/RequestChannel.scala
+++ b/core/src/main/scala/kafka/network/RequestChannel.scala
@@ -84,7 +84,7 @@ object RequestChannel extends Logging {
         header.toString + " -- " + body.toString
     }
 
-    trace("Processor %d received request : %s".format(processor, requestDesc(false)))
+    trace("Processor %d received request : %s".format(processor, requestDesc(true)))
 
     def updateRequestMetrics() {
       val endTimeMs = SystemTime.milliseconds
@@ -118,10 +118,10 @@ object RequestChannel extends Logging {
 
       if(requestLogger.isTraceEnabled)
         requestLogger.trace("Completed request:%s from connection %s;totalTime:%d,requestQueueTime:%d,localTime:%d,remoteTime:%d,responseQueueTime:%d,sendTime:%d,securityProtocol:%s,principal:%s"
-          .format(requestDesc(false), connectionId, totalTime, requestQueueTime, apiLocalTime,
apiRemoteTime, responseQueueTime, responseSendTime, securityProtocol, session.principal))
+          .format(requestDesc(true), connectionId, totalTime, requestQueueTime, apiLocalTime,
apiRemoteTime, responseQueueTime, responseSendTime, securityProtocol, session.principal))
       else if(requestLogger.isDebugEnabled)
         requestLogger.debug("Completed request:%s from connection %s;totalTime:%d,requestQueueTime:%d,localTime:%d,remoteTime:%d,responseQueueTime:%d,sendTime:%d,securityProtocol:%s,principal:%s"
-          .format(requestDesc(true), connectionId, totalTime, requestQueueTime, apiLocalTime,
apiRemoteTime, responseQueueTime, responseSendTime, securityProtocol, session.principal))
+          .format(requestDesc(false), connectionId, totalTime, requestQueueTime, apiLocalTime,
apiRemoteTime, responseQueueTime, responseSendTime, securityProtocol, session.principal))
     }
   }
   


Mime
View raw message