kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-1598; Fix variable typo in Kafka main class; patched by Jarek Jarcec Cecho; reviewed by Jun Rao
Date Mon, 18 Aug 2014 22:49:34 GMT
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 <jarcec@apache.org>
Authored: Mon Aug 18 15:49:29 2014 -0700
Committer: Jun Rao <junrao@gmail.com>
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)


Mime
View raw message