From c281ebf58c2e2312659c1517bad5a2bd04bf35a2 Mon Sep 17 00:00:00 2001 From: Jason Gustafson Date: Fri, 17 Feb 2017 15:59:08 -0800 Subject: [PATCH] HOTFIX: ClassCastException in requrest logging --- core/src/main/scala/kafka/network/RequestChannel.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/network/RequestChannel.scala b/core/src/main/scala/kafka/network/RequestChannel.scala index a5d71602eaeef..677f9b4fdbdc3 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] = {