Package io.quarkus.kafka.client.deployment

Class RedpandaKafkaContainer

java.lang.Object

org.testcontainers.containers.GenericContainer<RedpandaKafkaContainer>

io.quarkus.kafka.client.deployment.RedpandaKafkaContainer

All Implemented Interfaces:

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

final class RedpandaKafkaContainer
extends org.testcontainers.containers.GenericContainer<RedpandaKafkaContainer>
implements io.quarkus.deployment.builditem.Startable

Container configuring and starting the Redpanda broker. See https://docs.redpanda.com/current/get-started/quick-start/

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
RedpandaKafkaContainer(org.testcontainers.utility.DockerImageName dockerImageName, int fixedExposedPort, String defaultNetworkId, boolean useSharedNetwork, RedpandaBuildTimeConfig redpandaConfig)

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()
RedpandaKafkaContainer	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

RedpandaKafkaContainer

RedpandaKafkaContainer(org.testcontainers.utility.DockerImageName dockerImageName,
 int fixedExposedPort,
 String defaultNetworkId,
 boolean useSharedNetwork,
 RedpandaBuildTimeConfig redpandaConfig)

Method Details

withSharedServiceLabel

public RedpandaKafkaContainer 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<RedpandaKafkaContainer>

configure

protected void configure()

Overrides:

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

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