From e2dac4a834c84808a8d171dbfdc149f6207e6d4a Mon Sep 17 00:00:00 2001
From: Florian Hussonnois <florian.hussonnois@gmail.com>
Date: Fri, 20 May 2016 16:24:29 +0200
Subject: [PATCH] KAFKA-3737: Change log level for error during produce request

---
 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 086bd4b893db..0970d3bb0455 100644
--- a/core/src/main/scala/kafka/server/KafkaApis.scala
+++ b/core/src/main/scala/kafka/server/KafkaApis.scala
@@ -359,7 +359,7 @@ class KafkaApis(val requestChannel: RequestChannel,
             val exceptionsSummary = mergedResponseStatus.map { case (topicPartition, status) =>
               topicPartition -> Errors.forCode(status.errorCode).exceptionName
             }.mkString(", ")
-            info(
+            warn(
               s"Closing connection due to error during produce request with correlation id ${request.header.correlationId} " +
                 s"from client id ${request.header.clientId} with ack=0\n" +
                 s"Topic and partition to exceptions: $exceptionsSummary"