public ConfigStore<KafkaSchedulerConfiguration> getConfigStore() {
return configStore;
}
public KafkaSchedulerConfiguration fetch(UUID version) throws ConfigStoreException {
try {
<BUG>return configStore.fetch(version, KafkaSchedulerConfiguration.getFactoryInstance());
} catch (ConfigStoreException e) {</BUG>
log.error("Unable to fetch version: " + version, e);
throw new ConfigStoreException(e);
}

public ConfigStore<KafkaSchedulerConfiguration> getConfigStore() {
return configStore;
}
public KafkaSchedulerConfiguration fetch(UUID version) throws ConfigStoreException {
try {
return configStore.fetch(version);
} catch (ConfigStoreException e) {
log.error("Unable to fetch version: " + version, e);
throw new ConfigStoreException(e);
