package com.mesosphere.dcos.kafka.executor;
<BUG>import com.google.protobuf.InvalidProtocolBufferException;</BUG>
import org.apache.mesos.ExecutorDriver;
import org.apache.mesos.Protos;
import org.apache.mesos.executor.ExecutorTask;
import org.apache.mesos.executor.ExecutorTaskException;
import org.apache.mesos.executor.ExecutorTaskFactory;
<BUG>import org.apache.mesos.executor.ProcessTask;
public class KafkaExecutorTaskFactory implements ExecutorTaskFactory {</BUG>
@Override

package com.mesosphere.dcos.kafka.executor;
import org.apache.mesos.ExecutorDriver;
import org.apache.mesos.Protos;
import org.apache.mesos.executor.ExecutorTask;
import org.apache.mesos.executor.ExecutorTaskException;
import org.apache.mesos.executor.ExecutorTaskFactory;
import org.apache.mesos.executor.ProcessTask;
import java.io.IOException;
public class KafkaExecutorTaskFactory implements ExecutorTaskFactory {
@Override
