public
anonymous / gist:6688293
Created

delay property verification until after server startup

  • Download Gist
gistfile1.txt
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25
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 ***********/

Please sign in to comment on this gist.

Something went wrong with that request. Please try again.