diff --git a/core/src/main/scala/kafka/server/KafkaApis.scala b/core/src/main/scala/kafka/server/KafkaApis.scala index c90cace9bcfcb..fa5afe5f68ba4 100644 --- a/core/src/main/scala/kafka/server/KafkaApis.scala +++ b/core/src/main/scala/kafka/server/KafkaApis.scala @@ -117,7 +117,7 @@ class KafkaApis(val requestChannel: RequestChannel, else requestChannel.sendResponse(new Response(request, response)) - error("Error when handling request %s".format(request.body), e) + error("Error when handling request %s".format(request.body[AbstractRequest]), e) } } finally request.apiLocalCompleteTimeMs = time.milliseconds