import org.apache.kafka.common.security.auth.SecurityProtocol; //导入依赖的package包/类
public static Properties createKafkaConfig(int port, String zkConnect, boolean autoCreateTopic, int numPartitions) {
  final Option<File> noFile = scala.Option.apply(null);
  final Option<SecurityProtocol> noInterBrokerSecurityProtocol = scala.Option.apply(null);
  // new params for kafka 0.10.0
  Option<Properties> saslProperties = scala.Option.apply(null);
  Option<String> rack = scala.Option.apply(RackAwareMode.Enforced$.MODULE$.toString());

  Properties props = TestUtils.createBrokerConfig(
      0, zkConnect, false, false, port, noInterBrokerSecurityProtocol,
      noFile, saslProperties, true, false, TestUtils.RandomPort(), false, TestUtils.RandomPort(), false,
      TestUtils.RandomPort(), rack, 1);
  props.setProperty("auto.create.topics.enable", String.valueOf(autoCreateTopic));
  props.setProperty("num.partitions", String.valueOf(numPartitions));
  props.setProperty("offsets.topic.replication.factor", "1");
  return props;
}
 

import org.apache.kafka.common.security.auth.SecurityProtocol; //导入依赖的package包/类
public static KafkaServer createKafkaServer(int brokerId, int port, String zkConnect) {
  final Option<File> noFile = scala.Option.apply(null);
  final Option<SecurityProtocol> noInterBrokerSecurityProtocol = scala.Option.apply(null);
  // new params for kafka 0.10.0
  Option<Properties> saslProperties = scala.Option.apply(null);
  Option rack = scala.Option.apply(RackAwareMode.Enforced$.MODULE$.toString());
  Properties props = TestUtils.createBrokerConfig(
      brokerId,
      zkConnect,
      false,
      false,
      port,
      noInterBrokerSecurityProtocol,
      noFile,
      saslProperties,
      true,
      false,
      TestUtils.RandomPort(),
      false,
      TestUtils.RandomPort(),
      false,
      TestUtils.RandomPort(),
      rack,
      1
  );
  props.setProperty("auto.create.topics.enable", "true");
  props.setProperty("num.partitions", "1");
  props.setProperty("zookeeper.connect", zkConnect);
  KafkaConfig config = new KafkaConfig(props);
  return TestUtils.createServer(config, Time.SYSTEM);
}
 

import org.apache.kafka.common.security.auth.SecurityProtocol; //导入依赖的package包/类
private KafkaServer startKafkaServer() {
    Properties props = TestUtils.createBrokerConfig(0, zookeeper.getConnectString(), true, true, 9092, Option.<SecurityProtocol>empty(), Option.<File>empty(), Option.<Properties>empty(), true, false, 0, false, 0, false, 0, Option.<String>empty(), 0);
    props.put(KafkaConfig.ZkConnectProp(), zookeeper.getConnectString());
    kafkaServer = TestUtils.createServer(new KafkaConfig(props), new kafka.utils.MockTime());
    return kafkaServer;
}
 

import org.apache.kafka.common.security.auth.SecurityProtocol; //导入依赖的package包/类
/**
 * This broker's `metadata.broker.list` value.  Example: `127.0.0.1:9092`.
 * <p>
 * You can use this to tell Kafka producers and consumers how to connect to this instance.
 */
public String brokerList() {
  return kafka.config().hostName() + ":" + kafka.boundPort(ListenerName.forSecurityProtocol(SecurityProtocol.PLAINTEXT));
}