Package io.quarkus.kafka.client.deployment

Class KafkaNativeContainer

java.lang.Object

org.testcontainers.containers.GenericContainer<KafkaNativeContainer>

io.quarkus.kafka.client.deployment.KafkaNativeContainer

All Implemented Interfaces:

io.quarkus.deployment.builditem.Startable, Closeable, AutoCloseable, org.testcontainers.containers.Container<KafkaNativeContainer>, org.testcontainers.containers.ContainerState, org.testcontainers.containers.traits.LinkableContainer, org.testcontainers.containers.wait.strategy.WaitStrategyTarget, org.testcontainers.lifecycle.Startable

public class KafkaNativeContainer
extends org.testcontainers.containers.GenericContainer<KafkaNativeContainer>
implements io.quarkus.deployment.builditem.Startable

Nested Class Summary

Nested classes/interfaces inherited from interface org.testcontainers.containers.Container

org.testcontainers.containers.Container.ExecResult

Field Summary

Fields inherited from class org.testcontainers.containers.GenericContainer

CONTAINER_RUNNING_TIMEOUT_SEC, dependencies, dockerClient, INTERNAL_HOST_HOSTNAME, waitStrategy

Fields inherited from interface org.testcontainers.containers.ContainerState

STATE_HEALTHY

Constructor Summary

Constructors

Constructor	Description
KafkaNativeContainer(org.testcontainers.utility.DockerImageName dockerImageName, int fixedExposedPort, String defaultNetworkId, boolean useSharedNetwork)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	configure()
protected void	containerIsStarting(com.github.dockerjava.api.command.InspectContainerResponse containerInfo, boolean reused)
String	getBootstrapServers()
String	getConnectionInfo()
int	getExposedKafkaPort()
KafkaNativeContainer	withSharedServiceLabel(io.quarkus.runtime.LaunchMode launchMode, String serviceName)

Methods inherited from class org.testcontainers.containers.GenericContainer

addEnv, addExposedPort, addExposedPorts, addFileSystemBind, addFixedExposedPort, addFixedExposedPort, addLink, canBeReused, containerIsCreated, containerIsStarted, containerIsStarted, containerIsStarting, containerIsStopped, containerIsStopping, copyFileFromContainer, createVolumeDirectory, dependsOn, dependsOn, dependsOn, doStart, equals, getBinds, getCommandParts, getContainerId, getContainerInfo, getContainerName, getCopyToFileContainerPathMap, getCreateContainerCmdModifiers, getDependencies, getDockerClient, getDockerImageName, getEnv, getEnvMap, getExposedPorts, getExtraHosts, getImage, getIpAddress, getLabels, getLinkedContainers, getLivenessCheckPort, getLivenessCheckPortNumbers, getLivenessCheckPorts, getLogConsumers, getNetwork, getNetworkAliases, getNetworkMode, getPortBindings, getShmSize, getStartupAttempts, getStartupCheckStrategy, getTestHostIpAddress, getTmpFsMapping, getVolumesFroms, getWaitStrategy, getWorkingDirectory, hashCode, isHostAccessible, isPrivilegedMode, isShouldBeReused, logger, setBinds, setCommand, setCommand, setCommandParts, setContainerDef, setCopyToFileContainerPathMap, setDockerImageName, setEnv, setExposedPorts, setExtraHosts, setHostAccessible, setImage, setLabels, setLinkedContainers, setLogConsumers, setNetwork, setNetworkAliases, setNetworkMode, setPortBindings, setPrivilegedMode, setShmSize, setStartupAttempts, setStartupCheckStrategy, setTmpFsMapping, setVolumesFroms, setWaitStrategy, setWorkingDirectory, start, stop, toString, waitingFor, waitUntilContainerStarted, withAccessToHost, withClasspathResourceMapping, withClasspathResourceMapping, withCommand, withCommand, withCopyFileToContainer, withCopyToContainer, withCreateContainerCmdModifier, withEnv, withEnv, withExposedPorts, withExtraHost, withFileSystemBind, withImagePullPolicy, withLabel, withLabels, withLogConsumer, withMinimumRunningDuration, withNetwork, withNetworkAliases, withNetworkMode, withPrivilegedMode, withReuse, withSharedMemorySize, withStartupAttempts, withStartupCheckStrategy, withStartupTimeout, withTmpFs, withVolumesFrom, withWorkingDirectory

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.testcontainers.containers.Container

addFileSystemBind, followOutput, followOutput, self, withEnv, withFileSystemBind

Methods inherited from interface org.testcontainers.containers.ContainerState

copyFileFromContainer, copyFileToContainer, copyFileToContainer, execInContainer, execInContainer, execInContainer, execInContainer, execInContainerWithUser, execInContainerWithUser, getBoundPortNumbers, getContainerIpAddress, getCurrentContainerInfo, getFirstMappedPort, getHost, getLogs, getLogs, getMappedPort, isCreated, isHealthy, isRunning

Methods inherited from interface io.quarkus.deployment.builditem.Startable

getContainerId, start

Constructor Details

KafkaNativeContainer

public KafkaNativeContainer(org.testcontainers.utility.DockerImageName dockerImageName,
 int fixedExposedPort,
 String defaultNetworkId,
 boolean useSharedNetwork)

Method Details

withSharedServiceLabel

public KafkaNativeContainer withSharedServiceLabel(io.quarkus.runtime.LaunchMode launchMode,
 String serviceName)

containerIsStarting

protected void containerIsStarting(com.github.dockerjava.api.command.InspectContainerResponse containerInfo,
 boolean reused)

Overrides:

containerIsStarting in class org.testcontainers.containers.GenericContainer<KafkaNativeContainer>

getExposedKafkaPort

public int getExposedKafkaPort()

configure

protected void configure()

Overrides:

configure in class org.testcontainers.containers.GenericContainer<KafkaNativeContainer>

getBootstrapServers

public String getBootstrapServers()

getConnectionInfo

public String getConnectionInfo()

Specified by:

getConnectionInfo in interface io.quarkus.deployment.builditem.Startable

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.testcontainers.lifecycle.Startable