Repository: kafka Updated Branches: refs/heads/trunk 1f1e794ad -> a515e9357
HOTFIX: ClassCastException in request logging Author: Jason Gustafson <ja...@confluent.io> Reviewers: Colin P. Mccabe <cmcc...@confluent.io>, Ewen Cheslack-Postava <m...@ewencp.org> Closes #2566 from hachikuji/hotfix-request-logging Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a515e935 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/a515e935 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/a515e935 Branch: refs/heads/trunk Commit: a515e93570c5c117ca29fb05137898817f058fb9 Parents: 1f1e794 Author: Jason Gustafson <ja...@confluent.io> Authored: Fri Feb 17 16:31:00 2017 -0800 Committer: Jason Gustafson <ja...@confluent.io> Committed: Fri Feb 17 16:31:00 2017 -0800 ---------------------------------------------------------------------- core/src/main/scala/kafka/network/RequestChannel.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/a515e935/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 a5d7160..677f9b4 100644 --- a/core/src/main/scala/kafka/network/RequestChannel.scala +++ b/core/src/main/scala/kafka/network/RequestChannel.scala @@ -108,7 +108,7 @@ object RequestChannel extends Logging { if (requestObj != null) requestObj.describe(details) else - s"$header -- $body" + s"$header -- ${body[AbstractRequest]}" } def body[T <: AbstractRequest : ClassTag] = {
