import org.apache.mesos.scheduler.plan.Phase;

import java.util.ArrayList;</BUG>
import java.util.List;
<BUG>import java.util.UUID;
public class KafkaUpdatePhase extends ChainedObserver implements Phase {

private final List<Block> blocks;
private final String configName;
private final KafkaSchedulerConfiguration config;
private final UUID id;
public KafkaUpdatePhase(
</BUG>
String targetConfigName,

package com.mesosphere.dcos.kafka.plan;
import com.mesosphere.dcos.kafka.config.KafkaSchedulerConfiguration;
import com.mesosphere.dcos.kafka.offer.KafkaOfferRequirementProvider;
import com.mesosphere.dcos.kafka.state.FrameworkState;
import org.apache.mesos.scheduler.plan.DefaultPhase;
import org.apache.mesos.scheduler.plan.Step;
import org.apache.mesos.scheduler.plan.strategy.SerialStrategy;
import java.util.ArrayList;
import java.util.List;
public class KafkaUpdatePhase extends DefaultPhase {
public static KafkaUpdatePhase create(
String targetConfigName,
