def apply()

in testkit/src/main/scala/org/apache/pekko/kafka/testkit/KafkaTestkitTestcontainersSettings.scala [301:340]

• 29 lines of code
• 1 McCabe index (conditional complexity)

  def apply(system: ActorSystem): KafkaTestkitTestcontainersSettings =
    KafkaTestkitTestcontainersSettings(system.settings.config.getConfig(ConfigPath))

  /**
   * Java Api
   *
   * Create testkit testcontainers settings from ActorSystem settings.
   */
  def create(system: ActorSystem): KafkaTestkitTestcontainersSettings = KafkaTestkitTestcontainersSettings(system)

  /**
   * Create testkit testcontainres settings from a Config.
   */
  def apply(config: Config): KafkaTestkitTestcontainersSettings = {
    val zooKeeperImage = config.getString("zookeeper-image")
    val zooKeeperImageTag = config.getString("zookeeper-image-tag")
    val kafkaImage = config.getString("kafka-image")
    val kafkaImageTag = config.getString("kafka-image-tag")
    val schemaRegistryImage = config.getString("schema-registry-image")
    val schemaRegistryImageTag = config.getString("schema-registry-image-tag")
    val numBrokers = config.getInt("num-brokers")
    val internalTopicsReplicationFactor = config.getInt("internal-topics-replication-factor")
    val useSchemaRegistry = config.getBoolean("use-schema-registry")
    val containerLogging = config.getBoolean("container-logging")
    val clusterStartTimeout = config.getDuration("cluster-start-timeout").asScala
    val readinessCheckTimeout = config.getDuration("readiness-check-timeout").asScala

    new KafkaTestkitTestcontainersSettings(zooKeeperImage,
      zooKeeperImageTag,
      kafkaImage,
      kafkaImageTag,
      schemaRegistryImage,
      schemaRegistryImageTag,
      numBrokers,
      internalTopicsReplicationFactor,
      useSchemaRegistry,
      containerLogging,
      clusterStartTimeout,
      readinessCheckTimeout)
  }