You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2014/08/19 00:49:34 UTC
git commit: kafka-1598; Fix variable typo in Kafka main class;
patched by Jarek Jarcec Cecho; reviewed by Jun Rao
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 <ja...@apache.org>
Authored: Mon Aug 18 15:49:29 2014 -0700
Committer: Jun Rao <ju...@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)