Created
September 24, 2013 17:30
-
-
Save anonymous/6688293 to your computer and use it in GitHub Desktop.
delay property verification until after server startup
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/core/src/main/scala/kafka/Kafka.scala b/core/src/main/scala/kafka/Kafka.scala | |
index 988014a..1e541d4 100644 | |
--- a/core/src/main/scala/kafka/Kafka.scala | |
+++ b/core/src/main/scala/kafka/Kafka.scala | |
@@ -44,6 +44,7 @@ object Kafka extends Logging { | |
}) | |
kafkaServerStartble.startup | |
+ serverConfig.props.verify() | |
kafkaServerStartble.awaitShutdown | |
} | |
catch { | |
diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala b/core/src/main/scala/kafka/server/KafkaConfig.scala | |
index 41c9626..5f73586 100644 | |
--- a/core/src/main/scala/kafka/server/KafkaConfig.scala | |
+++ b/core/src/main/scala/kafka/server/KafkaConfig.scala | |
@@ -29,7 +29,7 @@ class KafkaConfig private (val props: VerifiableProperties) extends ZKConfig(pro | |
def this(originalProps: Properties) { | |
this(new VerifiableProperties(originalProps)) | |
- props.verify() | |
+ //props.verify() | |
} | |
/*********** General Configuration ***********/ |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment