root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

KAFKA-102 Patch from Blake Matheny. Clean up logging. 

git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1157920 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Edward Jay Kreps 2011-08-15 17:31:35 +00:00
parent d7e0b11d87
commit 7976993f9e
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/main/scala/kafka/log/LogManager.scala
View File

@ -275,10 +275,10 @@ private[kafka] class LogManager(val config: KafkaConfig,
} }
catch { catch {
case e => case e =>
logger.error("error flushing " + log.getTopicName, e) logger.error("Error flushing topic " + log.getTopicName, e)
e match { e match {
case _: IOException => 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) Runtime.getRuntime.halt(1)
case _ => case _ =>
} }

4
core/src/main/scala/kafka/server/KafkaRequestHandlers.scala
View File

@ -78,10 +78,10 @@ private[kafka] class KafkaRequestHandlers(val logManager: LogManager) {
} }
catch { catch {
case e => case e =>
logger.error("error processing " + requestHandlerName + " on " + request.topic + ":" + partition, e) logger.error("Error processing " + requestHandlerName + " on " + request.topic + ":" + partition, e)
e match { e match {
case _: IOException => 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) Runtime.getRuntime.halt(1)
case _ => case _ =>
} }