return kafkaConfigState;
}
public KafkaStateService getKafkaState() {
return kafkaStateService;
}
<BUG>private void setTargetConfig(KafkaSchedulerConfiguration newTargetConfig) throws StateStoreException {
String targetConfigName = UUID.randomUUID().toString();
kafkaConfigState.store(newTargetConfig, targetConfigName);</BUG>
kafkaConfigState.setTargetName(targetConfigName);
log.info("Set new target config: " + targetConfigName);

return kafkaConfigState;
}
public KafkaStateService getKafkaState() {
return kafkaStateService;
}
private void setTargetConfig(KafkaSchedulerConfiguration newTargetConfig) throws StateStoreException {
UUID targetConfigName = kafkaConfigState.store(newTargetConfig);
kafkaConfigState.setTargetName(targetConfigName);
log.info("Set new target config: " + targetConfigName);
