You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jj...@apache.org on 2014/08/06 01:00:04 UTC
[07/37] git commit: kafka-1513; Cleanup KafkaServerStartable code;
patched by Evgeny Vereshchagin; reviewed by Jun Rao
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/transactional_messaging
Commit: b1a1cae880817332f172dccaa5e3e4a69228074f
Parents: 2a4718c
Author: Evgeny Vereshchagin <ev...@ya.ru>
Authored: Wed Jul 2 22:09:26 2014 -0700
Committer: Jun Rao <ju...@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 {