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 _ =>
}
|