Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##: Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws(classOf[java.lang.CloneNotSupportedException]) @native()

6.  val clusterStartTimeout: FiniteDuration
7.  val configureKafka: (Vector[PekkoConnectorsKafkaContainer]) => Unit
8.  val configureKafkaConsumer: Consumer[Collection[PekkoConnectorsKafkaContainer]]
9.  val configureSchemaRegistry: (GenericContainer[_]) => Unit
10.  val configureZooKeeper: (GenericContainer[_]) => Unit
11.  val configureZooKeeperConsumer: Consumer[GenericContainer[_]]
12.  val containerLogging: Boolean
13.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

14.  def equals(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef → Any

15.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.Throwable])

16.  final def getClass(): Class[_ <: AnyRef]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

17.  def getClusterStartTimeout(): Duration

    Java Api

18.  def getContainerLogging(): Boolean

    Java Api

19.  def getInternalTopicsReplicationFactor(): Int

    Java Api

20.  def getKafkaImage(): String

    Java Api

21.  def getKafkaImageTag(): String

    Java Api

22.  def getNumBrokers(): Int

    Java Api

23.  def getReadinessCheckTimeout(): Duration

    Java Api

24.  def getSchemaRegistry(): Boolean

    Java Api

25.  def getSchemaRegistryImage(): String

    Java Api

26.  def getSchemaRegistryImageTag(): String

    Java Api

27.  def getZooKeeperImage(): String

    Java Api

28.  def getZooKeeperImageTag(): String

    Java Api

29.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

30.  val internalTopicsReplicationFactor: Int
31.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

32.  val kafkaImage: String
33.  val kafkaImageTag: String
34.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

35.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

36.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

37.  val numBrokers: Int
38.  val readinessCheckTimeout: FiniteDuration
39.  val schemaRegistryImage: String
40.  val schemaRegistryImageTag: String
41.  final def synchronized[T0](arg0: => T0): T0

    Definition Classes

    AnyRef

42.  def toString(): String

    Definition Classes

    KafkaTestkitTestcontainersSettings → AnyRef → Any

43.  val useSchemaRegistry: Boolean
44.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

45.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

46.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException]) @native()

47.  def withClusterStartTimeout(timeout: Duration): KafkaTestkitTestcontainersSettings

    Java Api

    Java Api

    Kafka cluster start up timeout

48.  def withClusterStartTimeout(timeout: FiniteDuration): KafkaTestkitTestcontainersSettings

    Kafka cluster start up timeout

49.  def withConfigureKafka(configureKafka: (Vector[PekkoConnectorsKafkaContainer]) => Unit): KafkaTestkitTestcontainersSettings

    Replaces the default Kafka testcontainers configuration logic

50.  def withConfigureKafkaConsumer(configureKafkaConsumer: Consumer[Collection[PekkoConnectorsKafkaContainer]]): KafkaTestkitTestcontainersSettings

    Java Api

    Java Api

    Replaces the default Kafka testcontainers configuration logic

51.  def withConfigureSchemaRegistry(configureSchemaRegistry: (GenericContainer[_]) => Unit): KafkaTestkitTestcontainersSettings

    Java Api Replaces the default schema registry testcontainers configuration logic

52.  def withConfigureZooKeeper(configureZooKeeper: (GenericContainer[_]) => Unit): KafkaTestkitTestcontainersSettings

    Replaces the default ZooKeeper testcontainers configuration logic

53.  def withConfigureZooKeeperConsumer(configureZooKeeperConsumer: Consumer[GenericContainer[_]]): KafkaTestkitTestcontainersSettings

    Java Api

    Java Api

    Replaces the default ZooKeeper testcontainers configuration logic

54.  def withContainerLogging(containerLogging: Boolean): KafkaTestkitTestcontainersSettings

    Stream container output to SLF4J logger(s).

55.  def withInternalTopicsReplicationFactor(internalTopicsReplicationFactor: Int): KafkaTestkitTestcontainersSettings

    Replaces the default internal Kafka topics replication factor

56.  def withKafkaImage(kafkaImage: String): KafkaTestkitTestcontainersSettings

    Sets the Kafka image

57.  def withKafkaImageTag(kafkaImageTag: String): KafkaTestkitTestcontainersSettings

    Sets the Kafka image tag

58.  def withNumBrokers(numBrokers: Int): KafkaTestkitTestcontainersSettings

    Replaces the default number of Kafka brokers

59.  def withReadinessCheckTimeout(timeout: Duration): KafkaTestkitTestcontainersSettings

    Java Api

    Java Api

    Kafka cluster readiness check timeout

60.  def withReadinessCheckTimeout(timeout: FiniteDuration): KafkaTestkitTestcontainersSettings

    Kafka cluster readiness check timeout

61.  def withSchemaRegistry(useSchemaRegistry: Boolean): KafkaTestkitTestcontainersSettings

    Use Schema Registry container.

62.  def withSchemaRegistryImage(schemaRegistryImage: String): KafkaTestkitTestcontainersSettings

    Sets the Schema Registry image

63.  def withSchemaRegistryImageTag(schemaRegistryImageTag: String): KafkaTestkitTestcontainersSettings

    Sets the Schema Registry image tag

64.  def withZooKeeperImage(zooKeeperImage: String): KafkaTestkitTestcontainersSettings

    Sets the ZooKeeper image

65.  def withZooKeeperImageTag(zooKeeperImageTag: String): KafkaTestkitTestcontainersSettings

    Sets the ZooKeeper image tag

66.  val zooKeeperImage: String
67.  val zooKeeperImageTag: String