Repository: kafka Updated Branches: refs/heads/0.10.0 5f9446498 -> 5aa20fb57
MINOR: Fix tracing in KafkaApis.handle() requestObj() returns null for the o.a.k.c.requests objects so use header() for these. Once all the requests will have been replaced by o.a.k.c.requests objects, we should be able to clean that up, but in the meantime it's useful to trace both. Author: Mickael Maison <[email protected]> Reviewers: Ismael Juma <[email protected]> Closes #1435 from mimaison/kafkaapis_trace (cherry picked from commit 936e26aa8db991b51141b21df234d702bc05408f) 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/5aa20fb5 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/5aa20fb5 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/5aa20fb5 Branch: refs/heads/0.10.0 Commit: 5aa20fb578dc8f20230a76ae8223fa013e590622 Parents: 5f94464 Author: Mickael Maison <[email protected]> Authored: Fri May 27 21:35:08 2016 +0100 Committer: Ismael Juma <[email protected]> Committed: Fri May 27 21:35:18 2016 +0100 ---------------------------------------------------------------------- core/src/main/scala/kafka/network/RequestChannel.scala | 2 +- core/src/main/scala/kafka/server/KafkaApis.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/5aa20fb5/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 e2000db..53a2346 100644 --- a/core/src/main/scala/kafka/network/RequestChannel.scala +++ b/core/src/main/scala/kafka/network/RequestChannel.scala @@ -100,7 +100,7 @@ object RequestChannel extends Logging { buffer = null private val requestLogger = Logger.getLogger("kafka.request.logger") - private def requestDesc(details: Boolean): String = { + def requestDesc(details: Boolean): String = { if (requestObj != null) requestObj.describe(details) else http://git-wip-us.apache.org/repos/asf/kafka/blob/5aa20fb5/core/src/main/scala/kafka/server/KafkaApis.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/server/KafkaApis.scala b/core/src/main/scala/kafka/server/KafkaApis.scala index 086bd4b..1edc162 100644 --- a/core/src/main/scala/kafka/server/KafkaApis.scala +++ b/core/src/main/scala/kafka/server/KafkaApis.scala @@ -71,7 +71,7 @@ class KafkaApis(val requestChannel: RequestChannel, def handle(request: RequestChannel.Request) { try { trace("Handling request:%s from connection %s;securityProtocol:%s,principal:%s". - format(request.requestObj, request.connectionId, request.securityProtocol, request.session.principal)) + format(request.requestDesc(true), request.connectionId, request.securityProtocol, request.session.principal)) ApiKeys.forId(request.requestId) match { case ApiKeys.PRODUCE => handleProducerRequest(request) case ApiKeys.FETCH => handleFetchRequest(request)
