import org.apache.mesos.offer.TaskUtils;
import org.apache.mesos.scheduler.recovery.TaskFailureListener;
import org.apache.mesos.state.StateStore;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
<BUG>import java.util.Arrays;
public class KafkaTaskFailureListener implements TaskFailureListener {</BUG>
private final Log log = LogFactory.getLog(getClass());
private final StateStore stateStore;
public KafkaTaskFailureListener(StateStore stateStore) {

import org.apache.mesos.offer.TaskUtils;
import org.apache.mesos.scheduler.recovery.TaskFailureListener;
import org.apache.mesos.state.StateStore;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import java.util.Arrays;
import java.util.Optional;
public class KafkaTaskFailureListener implements TaskFailureListener {
private final Log log = LogFactory.getLog(getClass());
private final StateStore stateStore;
public KafkaTaskFailureListener(StateStore stateStore) {
