import org.apache.mesos.protobuf.LabelBuilder;
import org.apache.mesos.protobuf.ValueBuilder;</BUG>
import java.io.IOException;
import java.net.URISyntaxException;
import java.util.*;
<BUG>import java.util.concurrent.ThreadLocalRandom;
public class PersistentOfferRequirementProvider implements KafkaOfferRequirementProvider {</BUG>
private final Log log = LogFactory.getLog(PersistentOfferRequirementProvider.class);
public static final String CONFIG_ID_KEY = "CONFIG_ID";
public static final String CONFIG_TARGET_KEY = "config_target";

import org.apache.mesos.config.ConfigStoreException;
import org.apache.mesos.offer.InvalidRequirementException;
import org.apache.mesos.offer.OfferRequirement;
import org.apache.mesos.offer.PlacementStrategy;
import org.apache.mesos.offer.ResourceUtils;
import java.io.IOException;
import java.net.URISyntaxException;
import java.util.*;
import java.util.concurrent.ThreadLocalRandom;
import java.util.stream.Collectors;
public class PersistentOfferRequirementProvider implements KafkaOfferRequirementProvider {
private final Log log = LogFactory.getLog(PersistentOfferRequirementProvider.class);
public static final String CONFIG_ID_KEY = "CONFIG_ID";
public static final String CONFIG_TARGET_KEY = "config_target";
