import org.slf4j.LoggerFactory;
import com.cloudera.oryx.common.io.IOUtils;
import com.cloudera.oryx.common.lang.JVMUtils;
import com.cloudera.oryx.common.settings.ConfigUtils;
public final class LocalKafkaBroker implements Closeable {
<BUG>public static final int TEST_BROKER_ID = 5;
private static final Logger log = LoggerFactory.getLogger(LocalKafkaBroker.class);</BUG>
private final int port;
private final int zkPort;
private Path logsDir;

import org.slf4j.LoggerFactory;
import com.cloudera.oryx.common.io.IOUtils;
import com.cloudera.oryx.common.lang.JVMUtils;
import com.cloudera.oryx.common.settings.ConfigUtils;
public final class LocalKafkaBroker implements Closeable {
static final int TEST_BROKER_ID = 5;
private static final Logger log = LoggerFactory.getLogger(LocalKafkaBroker.class);
private final int port;
private final int zkPort;
private Path logsDir;
