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