kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jkr...@apache.org
Subject svn commit: r1157920 - in /incubator/kafka/trunk/core/src/main/scala/kafka: log/LogManager.scala server/KafkaRequestHandlers.scala
Date Mon, 15 Aug 2011 17:31:35 GMT
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 _ =>
         }



Mime
View raw message