def getZooKeeperImage()

in testkit/src/main/scala/org/apache/pekko/kafka/testkit/KafkaTestkitTestcontainersSettings.scala [56:295]

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

  def getZooKeeperImage(): String = zooKeeperImage

  /**
   * Java Api
   */
  def getZooKeeperImageTag(): String = zooKeeperImageTag

  /**
   * Java Api
   */
  def getKafkaImage(): String = kafkaImage

  /**
   * Java Api
   */
  def getKafkaImageTag(): String = kafkaImageTag

  /**
   * Java Api
   */
  def getSchemaRegistryImage(): String = schemaRegistryImage

  /**
   * Java Api
   */
  def getSchemaRegistryImageTag(): String = schemaRegistryImageTag

  /**
   * Java Api
   */
  def getNumBrokers(): Int = numBrokers

  /**
   * Java Api
   */
  def getInternalTopicsReplicationFactor(): Int = internalTopicsReplicationFactor

  /**
   * Java Api
   */
  def getSchemaRegistry(): Boolean = useSchemaRegistry

  /**
   * Java Api
   */
  def getContainerLogging(): Boolean = containerLogging

  /**
   * Java Api
   */
  def getClusterStartTimeout(): Duration = clusterStartTimeout.asJava

  /**
   * Java Api
   */
  def getReadinessCheckTimeout(): Duration = readinessCheckTimeout.asJava

  /**
   * Sets the ZooKeeper image
   */
  def withZooKeeperImage(zooKeeperImage: String): KafkaTestkitTestcontainersSettings =
    copy(zooKeeperImage = zooKeeperImage)

  /**
   * Sets the ZooKeeper image tag
   */
  def withZooKeeperImageTag(zooKeeperImageTag: String): KafkaTestkitTestcontainersSettings =
    copy(zooKeeperImageTag = zooKeeperImageTag)

  /**
   * Sets the Kafka image
   */
  def withKafkaImage(kafkaImage: String): KafkaTestkitTestcontainersSettings =
    copy(kafkaImage = kafkaImage)

  /**
   * Sets the Kafka image tag
   */
  def withKafkaImageTag(kafkaImageTag: String): KafkaTestkitTestcontainersSettings =
    copy(kafkaImageTag = kafkaImageTag)

  /**
   * Sets the Schema Registry image
   */
  def withSchemaRegistryImage(schemaRegistryImage: String): KafkaTestkitTestcontainersSettings =
    copy(schemaRegistryImage = schemaRegistryImage)

  /**
   * Sets the Schema Registry image tag
   */
  def withSchemaRegistryImageTag(schemaRegistryImageTag: String): KafkaTestkitTestcontainersSettings =
    copy(schemaRegistryImageTag = schemaRegistryImageTag)

  /**
   * Replaces the default number of Kafka brokers
   */
  def withNumBrokers(numBrokers: Int): KafkaTestkitTestcontainersSettings =
    copy(numBrokers = numBrokers)

  /**
   * Replaces the default internal Kafka topics replication factor
   */
  def withInternalTopicsReplicationFactor(internalTopicsReplicationFactor: Int): KafkaTestkitTestcontainersSettings =
    copy(internalTopicsReplicationFactor = internalTopicsReplicationFactor)

  /**
   * Java Api
   *
   * Replaces the default Kafka testcontainers configuration logic
   */
  def withConfigureKafkaConsumer(
      configureKafkaConsumer: java.util.function.Consumer[java.util.Collection[PekkoConnectorsKafkaContainer]])
      : KafkaTestkitTestcontainersSettings = copy(configureKafkaConsumer = configureKafkaConsumer)

  /**
   * Replaces the default Kafka testcontainers configuration logic
   */
  def withConfigureKafka(
      configureKafka: Vector[PekkoConnectorsKafkaContainer] => Unit): KafkaTestkitTestcontainersSettings =
    copy(configureKafka = configureKafka)

  /**
   * Replaces the default ZooKeeper testcontainers configuration logic
   */
  def withConfigureZooKeeper(configureZooKeeper: GenericContainer[_] => Unit): KafkaTestkitTestcontainersSettings =
    copy(configureZooKeeper = configureZooKeeper)

  /**
   * Java Api
   *
   * Replaces the default ZooKeeper testcontainers configuration logic
   */
  def withConfigureZooKeeperConsumer(
      configureZooKeeperConsumer: java.util.function.Consumer[GenericContainer[_]])
      : KafkaTestkitTestcontainersSettings =
    copy(configureZooKeeperConsumer = configureZooKeeperConsumer)

  /**
   * Java Api
   * Replaces the default schema registry testcontainers configuration logic
   */
  def withConfigureSchemaRegistry(
      configureSchemaRegistry: GenericContainer[_] => Unit): KafkaTestkitTestcontainersSettings =
    copy(configureSchemaRegistry = configureSchemaRegistry)

  /**
   * Use Schema Registry container.
   */
  def withSchemaRegistry(useSchemaRegistry: Boolean): KafkaTestkitTestcontainersSettings =
    copy(useSchemaRegistry = useSchemaRegistry);

  /**
   * Stream container output to SLF4J logger(s).
   */
  def withContainerLogging(containerLogging: Boolean): KafkaTestkitTestcontainersSettings =
    copy(containerLogging = containerLogging)

  /**
   * Kafka cluster start up timeout
   */
  def withClusterStartTimeout(timeout: FiniteDuration): KafkaTestkitTestcontainersSettings =
    copy(clusterStartTimeout = timeout)

  /**
   * Java Api
   *
   * Kafka cluster start up timeout
   */
  def withClusterStartTimeout(timeout: Duration): KafkaTestkitTestcontainersSettings =
    copy(clusterStartTimeout = timeout.asScala)

  /**
   * Kafka cluster readiness check timeout
   */
  def withReadinessCheckTimeout(timeout: FiniteDuration): KafkaTestkitTestcontainersSettings =
    copy(readinessCheckTimeout = timeout)

  /**
   * Java Api
   *
   * Kafka cluster readiness check timeout
   */
  def withReadinessCheckTimeout(timeout: Duration): KafkaTestkitTestcontainersSettings =
    copy(readinessCheckTimeout = timeout.asScala)

  private def copy(
      zooKeeperImage: String = zooKeeperImage,
      zooKeeperImageTag: String = zooKeeperImageTag,
      kafkaImage: String = kafkaImage,
      kafkaImageTag: String = kafkaImageTag,
      schemaRegistryImage: String = schemaRegistryImage,
      schemaRegistryImageTag: String = schemaRegistryImageTag,
      numBrokers: Int = numBrokers,
      internalTopicsReplicationFactor: Int = internalTopicsReplicationFactor,
      useSchemaRegistry: Boolean = useSchemaRegistry,
      containerLogging: Boolean = containerLogging,
      clusterStartTimeout: FiniteDuration = clusterStartTimeout,
      readinessCheckTimeout: FiniteDuration = readinessCheckTimeout,
      configureKafka: Vector[PekkoConnectorsKafkaContainer] => Unit = configureKafka,
      configureKafkaConsumer: java.util.function.Consumer[java.util.Collection[PekkoConnectorsKafkaContainer]] =
        configureKafkaConsumer,
      configureZooKeeper: GenericContainer[_] => Unit = configureZooKeeper,
      configureZooKeeperConsumer: java.util.function.Consumer[GenericContainer[_]] = configureZooKeeperConsumer,
      configureSchemaRegistry: GenericContainer[_] => Unit = configureSchemaRegistry)
      : KafkaTestkitTestcontainersSettings =
    new KafkaTestkitTestcontainersSettings(zooKeeperImage,
      zooKeeperImageTag,
      kafkaImage,
      kafkaImageTag,
      schemaRegistryImage,
      schemaRegistryImageTag,
      numBrokers,
      internalTopicsReplicationFactor,
      useSchemaRegistry,
      containerLogging,
      clusterStartTimeout,
      readinessCheckTimeout,
      configureKafka,
      configureKafkaConsumer,
      configureZooKeeper,
      configureZooKeeperConsumer,
      configureSchemaRegistry)

  override def toString: String =
    "KafkaTestkitTestcontainersSettings(" +
    s"zooKeeperImage=$zooKeeperImage," +
    s"zooKeeperImageTag=$zooKeeperImageTag," +
    s"kafkaImage=$kafkaImage," +
    s"kafkaImageTag=$kafkaImageTag," +
    s"schemaRegistryImage=$schemaRegistryImage," +
    s"schemaRegistryImageTag=$schemaRegistryImageTag," +
    s"numBrokers=$numBrokers," +
    s"internalTopicsReplicationFactor=$internalTopicsReplicationFactor," +
    s"useSchemaRegistry=$useSchemaRegistry," +
    s"containerLogging=$containerLogging, +" +
    s"clusterStartTimeout=${clusterStartTimeout.toCoarsest}," +
    s"readinessCheckTimeout=${readinessCheckTimeout.toCoarsest})"
}

object KafkaTestkitTestcontainersSettings {