kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-1513; Cleanup KafkaServerStartable code; patched by Evgeny Vereshchagin; reviewed by Jun Rao
Date Thu, 03 Jul 2014 05:09:29 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 2a4718c1a -> b1a1cae88


kafka-1513; Cleanup KafkaServerStartable code; patched by Evgeny Vereshchagin; 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/b1a1cae8
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/b1a1cae8
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/b1a1cae8

Branch: refs/heads/trunk
Commit: b1a1cae880817332f172dccaa5e3e4a69228074f
Parents: 2a4718c
Author: Evgeny Vereshchagin <evvers@ya.ru>
Authored: Wed Jul 2 22:09:26 2014 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Wed Jul 2 22:09:26 2014 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/server/KafkaServerStartable.scala | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/b1a1cae8/core/src/main/scala/kafka/server/KafkaServerStartable.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/KafkaServerStartable.scala b/core/src/main/scala/kafka/server/KafkaServerStartable.scala
index cef3b84..28658bb 100644
--- a/core/src/main/scala/kafka/server/KafkaServerStartable.scala
+++ b/core/src/main/scala/kafka/server/KafkaServerStartable.scala
@@ -21,13 +21,7 @@ import kafka.utils.Logging
 
 
 class KafkaServerStartable(val serverConfig: KafkaConfig) extends Logging {
-  private var server : KafkaServer = null
-
-  init
-
-  private def init() {
-    server = new KafkaServer(serverConfig)
-  }
+  private val server = new KafkaServer(serverConfig)
 
   def startup() {
     try {


Mime
View raw message