import com.cloudera.oryx.kafka.util.ProduceData;
import com.cloudera.oryx.kafka.util.DatumGenerator;
import com.cloudera.oryx.lambda.AbstractLambdaIT;
public abstract class AbstractSpeedIT extends AbstractLambdaIT {
private static final Logger log = LoggerFactory.getLogger(AbstractSpeedIT.class);
<BUG>protected final List<Pair<String,String>> startServerProduceConsumeTopics(
Config config,</BUG>
int howMany,
int howManyUpdate) throws IOException, InterruptedException {
return startServerProduceConsumeTopics(config,

import com.cloudera.oryx.kafka.util.ProduceData;
import com.cloudera.oryx.kafka.util.DatumGenerator;
import com.cloudera.oryx.lambda.AbstractLambdaIT;
public abstract class AbstractSpeedIT extends AbstractLambdaIT {
private static final Logger log = LoggerFactory.getLogger(AbstractSpeedIT.class);
final List<Pair<String,String>> startServerProduceConsumeTopics(
Config config,
int howMany,
int howManyUpdate) throws IOException, InterruptedException {
return startServerProduceConsumeTopics(config,
