kafka-commits mailing list archives

Author: jkreps
Date: Mon Aug 15 17:31:35 2011
New Revision: 1157920

URL: http://svn.apache.org/viewvc?rev=1157920&view=rev
Log:
KAFKA-102 Patch from Blake Matheny. Clean up logging.


Modified:
    incubator/kafka/trunk/core/src/main/scala/kafka/log/LogManager.scala
    incubator/kafka/trunk/core/src/main/scala/kafka/server/KafkaRequestHandlers.scala

Modified: incubator/kafka/trunk/core/src/main/scala/kafka/log/LogManager.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/log/LogManager.scala?rev=1157920&r1=1157919&r2=1157920&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/log/LogManager.scala (original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/log/LogManager.scala Mon Aug 15 17:31:35
2011
@@ -275,10 +275,10 @@ private[kafka] class LogManager(val conf
       }
       catch {
         case e =>
-          logger.error("error flushing " + log.getTopicName, e)
+          logger.error("Error flushing topic " + log.getTopicName, e)
           e match {
             case _: IOException =>
-              logger.error("force shutdown due to error in flushAllLogs" + e)
+              logger.fatal("Halting due to unrecoverable I/O error while flushing logs: "
+ e.getMessage, e)
               Runtime.getRuntime.halt(1)
             case _ =>
           }

Modified: incubator/kafka/trunk/core/src/main/scala/kafka/server/KafkaRequestHandlers.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/server/KafkaRequestHandlers.scala?rev=1157920&r1=1157919&r2=1157920&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/server/KafkaRequestHandlers.scala (original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/server/KafkaRequestHandlers.scala Mon
Aug 15 17:31:35 2011
@@ -78,10 +78,10 @@ private[kafka] class KafkaRequestHandler
     }
     catch {
       case e =>
-        logger.error("error processing " + requestHandlerName + " on " + request.topic +
":" + partition, e)
+        logger.error("Error processing " + requestHandlerName + " on " + request.topic +
":" + partition, e)
         e match {
           case _: IOException =>
-            logger.error("force shutdown due to " + e)
+            logger.fatal("Halting due to unrecoverable I/O error while handling producer
request: " + e.getMessage, e)
             Runtime.getRuntime.halt(1)
           case _ =>
         }