Skip to content

anonymous /gist:6688293

delay property verification until after server startup
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
Something went wrong with that request. Please try again.