if(zookeeperLocalCluster.port == null) {
<BUG>this.port = Integer.parseInt(propertyParser.getProperty(ConfigVars.ZOOKEEPER_PORT_KEY));
}</BUG>
if(zookeeperLocalCluster.tempDir == null) {
<BUG>this.tempDir = propertyParser.getProperty(ConfigVars.ZOOKEEPER_TEMP_DIR_KEY);
}</BUG>
}
}
@Override
public void configure() {}

if(zookeeperLocalCluster.port == null) {
throw new IllegalArgumentException("ERROR: Missing required config: Zookeeper Port");
}
if(zookeeperLocalCluster.tempDir == null) {
throw new IllegalArgumentException("ERROR: Missing required config: Zookeeper Temp Dir");
}
if(zookeeperLocalCluster.zookeeperConnectionString == null) {
throw new IllegalArgumentException("ERROR: Missing required config: Zookeeper Connection String");
}
}
}
@Override
public void configure() {}
