From 4cbf63a54d7233e8fadddce19b7cabdd8a2d57fa Mon Sep 17 00:00:00 2001 From: Armin Braun Date: Sat, 18 Feb 2017 18:24:58 +0100 Subject: [PATCH] Fixed KafkaAPI Error Response --- core/src/main/scala/kafka/server/KafkaApis.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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