KAFKA-770 KafkaConfig properties should be verified in the constructor; reviewed by Neha Narkhede

This commit is contained in:
Swapnil Ghike 2013-02-22 08:13:31 -08:00 committed by Neha Narkhede
parent 049ac882bf
commit b056a9a1ec
2 changed files with 1 additions and 3 deletions

View File

@ -29,10 +29,9 @@ class KafkaConfig private (val props: VerifiableProperties) extends ZKConfig(pro
def this(originalProps: Properties) {
this(new VerifiableProperties(originalProps))
props.verify()
}
def verify() = props.verify()
/*********** General Configuration ***********/
/* the broker id for this server */

View File

@ -32,7 +32,6 @@ class KafkaServerStartable(val serverConfig: KafkaConfig) extends Logging {
def startup() {
try {
server.startup()
serverConfig.verify()
}
catch {
case e =>