diff --git a/core/src/main/scala/kafka/log/LogManager.scala b/core/src/main/scala/kafka/log/LogManager.scala
index 958614b..d79df73 100644
--- a/core/src/main/scala/kafka/log/LogManager.scala
+++ b/core/src/main/scala/kafka/log/LogManager.scala
@@ -278,7 +278,7 @@ private[kafka] class LogManager(val config: KafkaConfig,
           logger.error("error flushing " + log.getTopicName, e)
           e match {
             case _: IOException =>
-              logger.error("force shutdown due to error in flushAllLogs" + e)
+              logger.fatal("force shutdown due to error in flushAllLogs" + e)
               Runtime.getRuntime.halt(1)
             case _ =>
           }
diff --git a/core/src/main/scala/kafka/server/KafkaRequestHandlers.scala b/core/src/main/scala/kafka/server/KafkaRequestHandlers.scala
index 9124d60..c2662a3 100644
--- a/core/src/main/scala/kafka/server/KafkaRequestHandlers.scala
+++ b/core/src/main/scala/kafka/server/KafkaRequestHandlers.scala
@@ -81,7 +81,7 @@ private[kafka] class KafkaRequestHandlers(val logManager: LogManager) {
         logger.error("error processing " + requestHandlerName + " on " + request.topic + ":" + partition, e)
         e match {
           case _: IOException =>
-            logger.error("force shutdown due to " + e)
+            logger.fatal("force shutdown due to " + e)
             Runtime.getRuntime.halt(1)
           case _ =>
         }