import java.util.*;
public class KafkaConfigState {
private static final Log log = LogFactory.getLog(KafkaConfigState.class);
private final ConfigStore<KafkaSchedulerConfiguration> configStore;
public KafkaConfigState(ZookeeperConfiguration zkConfig) {
<BUG>this.configStore = new CuratorConfigStore<>(
zkConfig.getFrameworkName(), zkConfig.getMesosZkUri());</BUG>
}
public KafkaConfigState(String zkRoot, String zkHost, RetryPolicy retryPolicy) {
<BUG>this.configStore = new CuratorConfigStore<>(
zkRoot, zkHost, retryPolicy);</BUG>
}

import java.util.*;
public class KafkaConfigState {
private static final Log log = LogFactory.getLog(KafkaConfigState.class);
private final ConfigStore<KafkaSchedulerConfiguration> configStore;
public KafkaConfigState(ZookeeperConfiguration zkConfig) {
this.configStore = new CuratorConfigStore<>(
KafkaSchedulerConfiguration.getFactoryInstance(),
zkConfig.getFrameworkName(), zkConfig.getMesosZkUri());
}
public KafkaConfigState(String zkRoot, String zkHost, RetryPolicy retryPolicy) {
this.configStore = new CuratorConfigStore<>(
KafkaSchedulerConfiguration.getFactoryInstance(),
zkRoot, zkHost, retryPolicy);
}
