this.newTargetConfig = newTargetConfig;
final KafkaConfiguration kafkaConfiguration = newTargetConfig.getKafkaConfiguration();
final String frameworkName = newTargetConfig.getServiceConfiguration().getName();
this.kafkaConfigState = new KafkaConfigState(
frameworkName,
<BUG>kafkaConfiguration.getZkAddress(),

"/");</BUG>
this.kafkaStateService = new KafkaStateService(
kafkaConfiguration.getZkAddress(),

this.newTargetConfig = newTargetConfig;
final KafkaConfiguration kafkaConfiguration = newTargetConfig.getKafkaConfiguration();
final String frameworkName = newTargetConfig.getServiceConfiguration().getName();
this.kafkaConfigState = new KafkaConfigState(
frameworkName,
kafkaConfiguration.getZkAddress());
this.kafkaStateService = new KafkaStateService(
kafkaConfiguration.getZkAddress(),
