From 659bbcb0d316acf2affa712a460f825cd9119922 Mon Sep 17 00:00:00 2001 From: Ewen Cheslack-Postava Date: Wed, 15 Oct 2014 11:53:24 -0700 Subject: [PATCH] KAFKA-1108 Log IOException messages during controlled shutdown. --- core/src/main/scala/kafka/server/KafkaServer.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/kafka/server/KafkaServer.scala b/core/src/main/scala/kafka/server/KafkaServer.scala index 07c0a07..fd14a9b 100644 --- a/core/src/main/scala/kafka/server/KafkaServer.scala +++ b/core/src/main/scala/kafka/server/KafkaServer.scala @@ -236,6 +236,7 @@ class KafkaServer(val config: KafkaConfig, time: Time = SystemTime) extends Logg case ioe: java.io.IOException => channel.disconnect() channel = null + info("Error during controlled shutdown: %s".format(ioe.getMessage)) // ignore and try again } } -- 2.1.2