Packages

c

org.apache.pekko.kafka.testkit.internal

PekkoConnectorsKafkaContainer

class PekkoConnectorsKafkaContainer extends GenericContainer[PekkoConnectorsKafkaContainer]

This container wraps Confluent Kafka and Zookeeper (optionally)

This is a copy of KafkaContainer from testcontainers/testcontainers-java that we can tweak as needed

Annotations
@InternalApi()
Source
PekkoConnectorsKafkaContainer.java
Linear Supertypes
GenericContainer[PekkoConnectorsKafkaContainer], Startable, WaitStrategyTarget, AutoCloseable, Container[PekkoConnectorsKafkaContainer], ContainerState, LinkableContainer, FailureDetectingExternalResource, TestRule, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PekkoConnectorsKafkaContainer
  2. GenericContainer
  3. Startable
  4. WaitStrategyTarget
  5. AutoCloseable
  6. Container
  7. ContainerState
  8. LinkableContainer
  9. FailureDetectingExternalResource
  10. TestRule
  11. AnyRef
  12. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new PekkoConnectorsKafkaContainer(dockerImageName: DockerImageName)
  2. new PekkoConnectorsKafkaContainer()

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. def addEnv(arg0: String, arg1: String): Unit
    Definition Classes
    GenericContainer → Container
  5. def addExposedPort(arg0: Integer): Unit
    Definition Classes
    GenericContainer → Container
  6. def addExposedPorts(arg0: <repeated...>[Int]): Unit
    Definition Classes
    GenericContainer → Container
    Annotations
    @transient()
  7. def addFileSystemBind(arg0: String, arg1: String, arg2: BindMode, arg3: SelinuxContext): Unit
    Definition Classes
    GenericContainer → Container
  8. def addFixedExposedPort(arg0: Int, arg1: Int, arg2: InternetProtocol): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
  9. def addFixedExposedPort(arg0: Int, arg1: Int): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
  10. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  11. def canBeReused(): Boolean
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
  12. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  13. def close(): Unit
    Definition Classes
    Startable → AutoCloseable
  14. def configure(): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
  15. def containerIsCreated(arg0: String): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
  16. def containerIsStarted(arg0: InspectContainerResponse, arg1: Boolean): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
  17. def containerIsStarted(arg0: InspectContainerResponse): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
  18. def containerIsStarting(containerInfo: InspectContainerResponse, reused: Boolean): Unit
    Attributes
    protected[internal]
    Definition Classes
    PekkoConnectorsKafkaContainer → GenericContainer
    Annotations
    @Override()
  19. def containerIsStarting(arg0: InspectContainerResponse): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
  20. def containerIsStopped(arg0: InspectContainerResponse): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
  21. def containerIsStopping(arg0: InspectContainerResponse): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
  22. def copyFileFromContainer(arg0: String, arg1: String): Unit
    Definition Classes
    GenericContainer → ContainerState
  23. def copyFileFromContainer[T <: AnyRef](arg0: String, arg1: ThrowingFunction[InputStream, T]): T
    Definition Classes
    ContainerState
  24. def copyFileToContainer(arg0: Transferable, arg1: String): Unit
    Definition Classes
    ContainerState
  25. def copyFileToContainer(arg0: MountableFile, arg1: String): Unit
    Definition Classes
    ContainerState
  26. def dependsOn(arg0: Iterable[_ <: Startable]): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer
  27. def dependsOn(arg0: List[_ <: Startable]): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer
  28. def dependsOn(arg0: <repeated...>[Startable]): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer
    Annotations
    @transient()
  29. def doStart(): Unit
    Attributes
    protected[internal]
    Definition Classes
    PekkoConnectorsKafkaContainer → GenericContainer
    Annotations
    @Override()
  30. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  31. def equals(arg0: AnyRef): Boolean
    Definition Classes
    GenericContainer → AnyRef → Any
  32. def execInContainer(arg0: Charset, arg1: ExecConfig): ExecResult
    Definition Classes
    ContainerState
    Annotations
    @throws(classOf[java.lang.UnsupportedOperationException]) @throws(classOf[java.io.IOException]) @throws(classOf[java.lang.InterruptedException])
  33. def execInContainer(arg0: ExecConfig): ExecResult
    Definition Classes
    ContainerState
    Annotations
    @throws(classOf[java.lang.UnsupportedOperationException]) @throws(classOf[java.io.IOException]) @throws(classOf[java.lang.InterruptedException])
  34. def execInContainer(arg0: Charset, arg1: <repeated...>[String]): ExecResult
    Definition Classes
    ContainerState
    Annotations
    @throws(classOf[java.lang.UnsupportedOperationException]) @throws(classOf[java.io.IOException]) @throws(classOf[java.lang.InterruptedException]) @transient()
  35. def execInContainer(arg0: <repeated...>[String]): ExecResult
    Definition Classes
    ContainerState
    Annotations
    @throws(classOf[java.lang.UnsupportedOperationException]) @throws(classOf[java.io.IOException]) @throws(classOf[java.lang.InterruptedException]) @transient()
  36. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  37. def followOutput(arg0: Consumer[OutputFrame], arg1: <repeated...>[OutputType]): Unit
    Definition Classes
    Container
    Annotations
    @transient()
  38. def followOutput(arg0: Consumer[OutputFrame]): Unit
    Definition Classes
    Container
  39. def getBinds(): List[Bind]
    Definition Classes
    GenericContainer → Container
  40. def getBootstrapServers(): String
  41. def getBoundPortNumbers(): List[Integer]
    Definition Classes
    ContainerState
  42. def getBrokerNum(): Int
  43. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  44. def getCommandParts(): Array[String]
    Definition Classes
    GenericContainer → Container
  45. def getContainerId(): String
    Definition Classes
    GenericContainer → ContainerState
  46. def getContainerInfo(): InspectContainerResponse
    Definition Classes
    GenericContainer → ContainerState
  47. def getContainerName(): String
    Definition Classes
    GenericContainer → LinkableContainer
  48. def getCreateContainerCmdModifiers(): Set[CreateContainerCmdModifier]
    Definition Classes
    GenericContainer
  49. def getCurrentContainerInfo(): InspectContainerResponse
    Definition Classes
    ContainerState
  50. def getDependencies(): Set[Startable]
    Definition Classes
    GenericContainer → Startable
  51. def getDockerClient(): DockerClient
    Definition Classes
    GenericContainer → ContainerState
  52. def getDockerImageName(): String
    Definition Classes
    GenericContainer → Container
  53. def getEnv(): List[String]
    Definition Classes
    GenericContainer → Container
  54. def getEnvMap(): Map[String, String]
    Definition Classes
    GenericContainer → Container
  55. def getExposedPorts(): List[Integer]
    Definition Classes
    GenericContainer → ContainerState
  56. def getExtraHosts(): List[String]
    Definition Classes
    GenericContainer → Container
  57. def getFirstMappedPort(): Integer
    Definition Classes
    ContainerState
  58. def getHost(): String
    Definition Classes
    ContainerState
  59. def getImage(): RemoteDockerImage
    Definition Classes
    GenericContainer → Container
  60. def getJmxServiceUrl(): String
  61. def getLabels(): Map[String, String]
    Definition Classes
    GenericContainer
  62. def getLivenessCheckPortNumbers(): Set[Integer]
    Definition Classes
    GenericContainer → WaitStrategyTarget
  63. def getLogConsumers(): List[Consumer[OutputFrame]]
    Definition Classes
    GenericContainer
  64. def getLogs(arg0: <repeated...>[OutputType]): String
    Definition Classes
    ContainerState
    Annotations
    @transient()
  65. def getLogs(): String
    Definition Classes
    ContainerState
  66. def getMappedPort(arg0: Int): Integer
    Definition Classes
    ContainerState
  67. def getNetwork(): Network
    Definition Classes
    PekkoConnectorsKafkaContainer → GenericContainer
    Annotations
    @Override()
  68. def getNetworkAliases(): List[String]
    Definition Classes
    GenericContainer
  69. def getNetworkMode(): String
    Definition Classes
    GenericContainer
  70. def getPortBindings(): List[String]
    Definition Classes
    GenericContainer → Container → ContainerState
  71. def getShmSize(): Long
    Definition Classes
    GenericContainer
  72. def getStartupAttempts(): Int
    Definition Classes
    GenericContainer
  73. def getStartupCheckStrategy(): StartupCheckStrategy
    Definition Classes
    GenericContainer
  74. def getTmpFsMapping(): Map[String, String]
    Definition Classes
    GenericContainer
  75. def getVolumesFroms(): List[VolumesFrom]
    Definition Classes
    GenericContainer
  76. def getWaitStrategy(): WaitStrategy
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
  77. def getWorkingDirectory(): String
    Definition Classes
    GenericContainer
  78. def hashCode(): Int
    Definition Classes
    GenericContainer → AnyRef → Any
  79. def isCreated(): Boolean
    Definition Classes
    ContainerState
  80. def isHealthy(): Boolean
    Definition Classes
    ContainerState
  81. def isHostAccessible(): Boolean
    Definition Classes
    GenericContainer
  82. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  83. def isPrivilegedMode(): Boolean
    Definition Classes
    GenericContainer
  84. def isRunning(): Boolean
    Definition Classes
    ContainerState
  85. def isShouldBeReused(): Boolean
    Definition Classes
    GenericContainer
  86. def logger(): Logger
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
  87. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  88. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  89. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  90. def self(): PekkoConnectorsKafkaContainer
    Definition Classes
    Container
  91. def setBinds(arg0: List[Bind]): Unit
    Definition Classes
    GenericContainer → Container
  92. def setCommand(arg0: <repeated...>[String]): Unit
    Definition Classes
    GenericContainer → Container
    Annotations
    @transient()
  93. def setCommand(arg0: String): Unit
    Definition Classes
    GenericContainer → Container
  94. def setCommandParts(arg0: Array[String]): Unit
    Definition Classes
    GenericContainer → Container
  95. def setContainerDef(arg0: ContainerDef): Unit
    Definition Classes
    GenericContainer
  96. def setDockerImageName(arg0: String): Unit
    Definition Classes
    GenericContainer → Container
  97. def setEnv(arg0: List[String]): Unit
    Definition Classes
    GenericContainer → Container
  98. def setExposedPorts(arg0: List[Integer]): Unit
    Definition Classes
    GenericContainer → Container
  99. def setExtraHosts(arg0: List[String]): Unit
    Definition Classes
    GenericContainer → Container
  100. def setHostAccessible(arg0: Boolean): Unit
    Definition Classes
    GenericContainer
  101. def setImage(arg0: Future[String]): Unit
    Definition Classes
    GenericContainer → Container
  102. def setLabels(arg0: Map[String, String]): Unit
    Definition Classes
    GenericContainer
  103. def setLogConsumers(arg0: List[Consumer[OutputFrame]]): Unit
    Definition Classes
    GenericContainer
  104. def setNetwork(arg0: Network): Unit
    Definition Classes
    GenericContainer
  105. def setNetworkAliases(arg0: List[String]): Unit
    Definition Classes
    GenericContainer
  106. def setNetworkMode(arg0: String): Unit
    Definition Classes
    GenericContainer
  107. def setPortBindings(arg0: List[String]): Unit
    Definition Classes
    GenericContainer → Container
  108. def setPrivilegedMode(arg0: Boolean): Unit
    Definition Classes
    GenericContainer
  109. def setShmSize(arg0: Long): Unit
    Definition Classes
    GenericContainer
  110. def setStartupAttempts(arg0: Int): Unit
    Definition Classes
    GenericContainer
  111. def setStartupCheckStrategy(arg0: StartupCheckStrategy): Unit
    Definition Classes
    GenericContainer
  112. def setTmpFsMapping(arg0: Map[String, String]): Unit
    Definition Classes
    GenericContainer
  113. def setVolumesFroms(arg0: List[VolumesFrom]): Unit
    Definition Classes
    GenericContainer
  114. def setWaitStrategy(arg0: WaitStrategy): Unit
    Definition Classes
    GenericContainer → Container
  115. def setWorkingDirectory(arg0: String): Unit
    Definition Classes
    GenericContainer
  116. def start(): Unit
    Definition Classes
    GenericContainer → Startable
  117. def startKafka(): Unit
  118. def stop(): Unit
    Definition Classes
    GenericContainer → Startable
  119. def stopKafka(): Unit
  120. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  121. def toString(): String
    Definition Classes
    GenericContainer → AnyRef → Any
  122. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  123. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  124. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  125. def waitUntilContainerStarted(): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
  126. def waitingFor(arg0: WaitStrategy): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  127. def withAccessToHost(arg0: Boolean): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer
  128. def withBrokerNum(brokerNum: Int): PekkoConnectorsKafkaContainer
  129. def withClasspathResourceMapping(arg0: String, arg1: String, arg2: BindMode, arg3: SelinuxContext): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  130. def withClasspathResourceMapping(arg0: String, arg1: String, arg2: BindMode): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  131. def withCommand(arg0: <repeated...>[String]): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
    Annotations
    @transient()
  132. def withCommand(arg0: String): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  133. def withCopyFileToContainer(arg0: MountableFile, arg1: String): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  134. def withCopyToContainer(arg0: Transferable, arg1: String): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  135. def withCreateContainerCmdModifier(arg0: Consumer[CreateContainerCmd]): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer
  136. def withEmbeddedZookeeper(): PekkoConnectorsKafkaContainer
  137. def withEnv(arg0: Map[String, String]): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  138. def withEnv(arg0: String, arg1: String): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  139. def withEnv(arg0: String, arg1: Function[Optional[String], String]): PekkoConnectorsKafkaContainer
    Definition Classes
    Container
  140. def withExposedPorts(arg0: <repeated...>[Integer]): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
    Annotations
    @transient()
  141. def withExternalZookeeper(connectString: String): PekkoConnectorsKafkaContainer
  142. def withExtraHost(arg0: String, arg1: String): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  143. def withFileSystemBind(arg0: String, arg1: String, arg2: BindMode): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  144. def withImagePullPolicy(arg0: ImagePullPolicy): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  145. def withLabel(arg0: String, arg1: String): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  146. def withLabels(arg0: Map[String, String]): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  147. def withLogConsumer(arg0: Consumer[OutputFrame]): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  148. def withMinimumRunningDuration(arg0: Duration): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  149. def withNetwork(network: Network): PekkoConnectorsKafkaContainer
    Definition Classes
    PekkoConnectorsKafkaContainer → GenericContainer → Container
    Annotations
    @Override()
  150. def withNetworkAliases(arg0: <repeated...>[String]): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
    Annotations
    @transient()
  151. def withNetworkMode(arg0: String): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  152. def withPrivilegedMode(arg0: Boolean): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  153. def withRemoteJmxService(): PekkoConnectorsKafkaContainer
  154. def withReuse(arg0: Boolean): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer
  155. def withSharedMemorySize(arg0: Long): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer
  156. def withStartupAttempts(arg0: Int): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer
  157. def withStartupCheckStrategy(arg0: StartupCheckStrategy): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  158. def withStartupTimeout(arg0: Duration): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  159. def withTmpFs(arg0: Map[String, String]): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer
  160. def withVolumesFrom(arg0: Container[SELF] forSome {type SELF <: Container[SELF]}, arg1: BindMode): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container
  161. def withWorkingDirectory(arg0: String): PekkoConnectorsKafkaContainer
    Definition Classes
    GenericContainer → Container

Deprecated Value Members

  1. def addFileSystemBind(arg0: String, arg1: String, arg2: BindMode): Unit
    Definition Classes
    Container
    Annotations
    @Deprecated
    Deprecated
  2. def addLink(arg0: LinkableContainer, arg1: String): Unit
    Definition Classes
    GenericContainer → Container
    Annotations
    @Deprecated
    Deprecated
  3. def apply(arg0: Statement, arg1: Description): Statement
    Definition Classes
    GenericContainer → FailureDetectingExternalResource → TestRule
    Annotations
    @Deprecated
    Deprecated
  4. def createVolumeDirectory(arg0: Boolean): Path
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
    Annotations
    @Deprecated
    Deprecated
  5. def execInContainerWithUser(arg0: Charset, arg1: String, arg2: <repeated...>[String]): ExecResult
    Definition Classes
    ContainerState
    Annotations
    @throws(classOf[java.lang.UnsupportedOperationException]) @throws(classOf[java.io.IOException]) @throws(classOf[java.lang.InterruptedException]) @Deprecated @transient()
    Deprecated
  6. def execInContainerWithUser(arg0: String, arg1: <repeated...>[String]): ExecResult
    Definition Classes
    ContainerState
    Annotations
    @throws(classOf[java.lang.UnsupportedOperationException]) @throws(classOf[java.io.IOException]) @throws(classOf[java.lang.InterruptedException]) @Deprecated @transient()
    Deprecated
  7. def failed(arg0: Throwable, arg1: Description): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer → FailureDetectingExternalResource
    Annotations
    @Deprecated
    Deprecated
  8. def finished(arg0: Description): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer → FailureDetectingExternalResource
    Annotations
    @Deprecated
    Deprecated
  9. def getContainerIpAddress(): String
    Definition Classes
    ContainerState
    Annotations
    @Deprecated
    Deprecated
  10. def getCopyToFileContainerPathMap(): Map[MountableFile, String]
    Definition Classes
    GenericContainer
    Annotations
    @Deprecated
    Deprecated
  11. def getIpAddress(): String
    Definition Classes
    GenericContainer
    Annotations
    @Deprecated
    Deprecated
  12. def getLinkedContainers(): Map[String, LinkableContainer]
    Definition Classes
    GenericContainer → Container
    Annotations
    @Deprecated
    Deprecated
  13. def getLivenessCheckPort(): Integer
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
    Annotations
    @Deprecated
    Deprecated
  14. def getLivenessCheckPorts(): Set[Integer]
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer
    Annotations
    @Deprecated
    Deprecated
  15. def getTestHostIpAddress(): String
    Definition Classes
    GenericContainer → Container
    Annotations
    @Deprecated
    Deprecated
  16. def setCopyToFileContainerPathMap(arg0: Map[MountableFile, String]): Unit
    Definition Classes
    GenericContainer
    Annotations
    @Deprecated
    Deprecated
  17. def setLinkedContainers(arg0: Map[String, LinkableContainer]): Unit
    Definition Classes
    GenericContainer → Container
    Annotations
    @Deprecated
    Deprecated
  18. def starting(arg0: Description): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer → FailureDetectingExternalResource
    Annotations
    @Deprecated
    Deprecated
  19. def succeeded(arg0: Description): Unit
    Attributes
    protected[containers]
    Definition Classes
    GenericContainer → FailureDetectingExternalResource
    Annotations
    @Deprecated
    Deprecated
  20. def withFileSystemBind(arg0: String, arg1: String): PekkoConnectorsKafkaContainer
    Definition Classes
    Container
    Annotations
    @Deprecated
    Deprecated

Inherited from GenericContainer[PekkoConnectorsKafkaContainer]

Inherited from Startable

Inherited from WaitStrategyTarget

Inherited from AutoCloseable

Inherited from Container[PekkoConnectorsKafkaContainer]

Inherited from ContainerState

Inherited from LinkableContainer

Inherited from FailureDetectingExternalResource

Inherited from TestRule

Inherited from AnyRef

Inherited from Any

Ungrouped