Repository: kafka Updated Branches: refs/heads/trunk 780225506 -> f402b7a96
kafka-1598; Fix variable typo in Kafka main class; patched by Jarek Jarcec Cecho; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f402b7a9 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/f402b7a9 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/f402b7a9 Branch: refs/heads/trunk Commit: f402b7a96d802c1cf8624416c98da416e193e7fd Parents: 7802255 Author: Jarek Jarcec Cecho <[email protected]> Authored: Mon Aug 18 15:49:29 2014 -0700 Committer: Jun Rao <[email protected]> Committed: Mon Aug 18 15:49:29 2014 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/Kafka.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/f402b7a9/core/src/main/scala/kafka/Kafka.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/Kafka.scala b/core/src/main/scala/kafka/Kafka.scala index 988014a..2e94fee 100644 --- a/core/src/main/scala/kafka/Kafka.scala +++ b/core/src/main/scala/kafka/Kafka.scala @@ -34,17 +34,17 @@ object Kafka extends Logging { val props = Utils.loadProps(args(0)) val serverConfig = new KafkaConfig(props) KafkaMetricsReporter.startReporters(serverConfig.props) - val kafkaServerStartble = new KafkaServerStartable(serverConfig) + val kafkaServerStartable = new KafkaServerStartable(serverConfig) // attach shutdown handler to catch control-c Runtime.getRuntime().addShutdownHook(new Thread() { override def run() = { - kafkaServerStartble.shutdown + kafkaServerStartable.shutdown } }) - kafkaServerStartble.startup - kafkaServerStartble.awaitShutdown + kafkaServerStartable.startup + kafkaServerStartable.awaitShutdown } catch { case e: Throwable => fatal(e)
