<BUG>kafkaConfiguration.getZkAddress(),"/");</BUG><CONTEXT>this.newTargetConfig = newTargetConfig;final KafkaConfiguration kafkaConfiguration = newTargetConfig.getKafkaConfiguration();final String frameworkName = newTargetConfig.getServiceConfiguration().getName();this.kafkaConfigState = new KafkaConfigState(frameworkName,<extra_id_0>this.kafkaStateService = new KafkaStateService(kafkaConfiguration.getZkAddress(),</CONTEXT>
kafkaConfiguration.getZkAddress());