Index: core/src/main/scala/kafka/server/KafkaServer.scala =================================================================== --- core/src/main/scala/kafka/server/KafkaServer.scala (revision 1207637) +++ core/src/main/scala/kafka/server/KafkaServer.scala (working copy) @@ -81,7 +81,7 @@ catch { case e => fatal("Fatal error during startup.", e) - shutdown + Runtime.getRuntime.halt(1) } }