com.github.ydespreaux.testcontainers.kafka.containers

Class KafkaConnectContainer

java.lang.Object

org.testcontainers.containers.FailureDetectingExternalResource

org.testcontainers.containers.GenericContainer<SELF>

org.testcontainers.containers.FixedHostPortGenericContainer<KafkaConnectContainer>

com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

All Implemented Interfaces:

IContainer<KafkaConnectContainer>, AutoCloseable, org.junit.rules.TestRule, org.testcontainers.containers.Container<KafkaConnectContainer>, org.testcontainers.containers.ContainerState, org.testcontainers.containers.traits.LinkableContainer, org.testcontainers.containers.wait.strategy.WaitStrategyTarget, org.testcontainers.lifecycle.Startable

public class KafkaConnectContainer
extends org.testcontainers.containers.FixedHostPortGenericContainer<KafkaConnectContainer>
implements IContainer<KafkaConnectContainer>

Define Kafka connect container.

Since:

1.0.0

Author:

Yoann Despréaux

Nested Class Summary

Nested classes/interfaces inherited from class org.testcontainers.containers.GenericContainer

org.testcontainers.containers.GenericContainer.AbstractWaitStrategy

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

org.testcontainers.containers.Container.ExecResult

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONFIG_STORAGE_TOPIC_CONFIG
static String	GROUP_ID_CONFIG Key / value for Configuration
static String	KEY_CONVERTER_CONFIG
static String	KEY_CONVERTER_SCHEMA_REGISTRY_URL_CONFIG
static String	OFFSET_STORAGE_FILE_FILENAME_CONFIG
static String	OFFSET_STORAGE_PARTITIONS_CONFIG
static String	OFFSET_STORAGE_TOPIC_CONFIG
static String	STATUS_STORAGE_PARTITIONS_CONFIG
static String	STATUS_STORAGE_TOPIC_CONFIG
static String	VALUE_CONVERTER_CONFIG
static String	VALUE_CONVERTER_SCHEMA_REGISTRY_URL_CONFIG

Fields inherited from class org.testcontainers.containers.GenericContainer

CONTAINER_RUNNING_TIMEOUT_SEC, containerId, containerName, dockerClient, dockerDaemonInfo, INTERNAL_HOST_HOSTNAME, waitStrategy

Fields inherited from interface org.testcontainers.containers.ContainerState

STATE_HEALTHY

Constructor Summary

Constructors

Constructor and Description
KafkaConnectContainer(String version)
KafkaConnectContainer(String version, int restAppMappingPort)

Method Summary

Modifier and Type	Method and Description
protected void	configure() Configure de the container
boolean	equals(Object o)
String	getInternalURL() Get the local url
String	getURL() Get the url.
int	hashCode()
protected void	registerKafkaConnectEnvironment() Register system properties.
boolean	registerSpringbootProperties() Check if system properties must be registred.
void	start() Start the container
KafkaConnectContainer	withBrokersServerUrl(String brokersServerUrl)
KafkaConnectContainer	withConfigStorageTopic(String topic) Set the config storage topic.
KafkaConnectContainer	withGroupId(String groupId) Set the group id
KafkaConnectContainer	withKeyConverter(String keyConverter) Set the key converter.
KafkaConnectContainer	withOffsetStorageFilename(String storageFilename) Set the offsets storage file name.
KafkaConnectContainer	withOffsetStoragePartition(Integer partitions) Set the offsets storage partition.
KafkaConnectContainer	withOffsetStorageTopic(String topic) Set the topic name of the storage offsets topic.
KafkaConnectContainer	withPlugins(Set<String> plugins) Set the list of plugins directory.
KafkaConnectContainer	withPlugins(String plugins) Set the plugins directory.
KafkaConnectContainer	withRegisterSpringbootProperties(boolean registerProperties) Set if the sytem properties must be registred.
KafkaConnectContainer	withRestAppSystemProperty(String restAppSystemProperty)
KafkaConnectContainer	withSchemaRegistryUrl(String schemaRegistryUrl)
KafkaConnectContainer	withServerCertificates(Certificates certificates)
KafkaConnectContainer	withStatusStoragePartition(Integer partitions) Set the status storage partition.
KafkaConnectContainer	withStatusStorageTopic(String topic) Set the status storage topic's name.
KafkaConnectContainer	withValueConverter(String valueConverter) Set the value converter.

Methods inherited from class org.testcontainers.containers.FixedHostPortGenericContainer

withFixedExposedPort, withFixedExposedPort

Methods inherited from class org.testcontainers.containers.GenericContainer

addEnv, addExposedPort, addExposedPorts, addFileSystemBind, addFixedExposedPort, addFixedExposedPort, addLink, apply, canEqual, containerIsCreated, containerIsStarted, containerIsStarting, copyFileFromContainer, copyFileFromContainer, copyFileToContainer, copyFileToContainer, createVolumeDirectory, doStart, execInContainer, execInContainer, failed, fetchDockerDaemonInfo, finished, getBinds, getCommandParts, getContainerId, getContainerInfo, getContainerName, getCopyToFileContainerPathMap, getCreateContainerCmdModifiers, getDockerClient, getDockerDaemonInfo, 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, isPrivilegedMode, logger, setBinds, setCommand, setCommand, setCommandParts, setCopyToFileContainerPathMap, setDockerImageName, setEnv, setExposedPorts, setExtraHosts, setImage, setLabels, setLinkedContainers, setLogConsumers, setNetwork, setNetworkAliases, setNetworkMode, setPortBindings, setPrivilegedMode, setShmSize, setStartupAttempts, setStartupCheckStrategy, setTmpFsMapping, setVolumesFroms, setWaitStrategy, setWorkingDirectory, starting, stop, succeeded, toString, waitingFor, waitUntilContainerStarted, withClasspathResourceMapping, withClasspathResourceMapping, withCommand, withCommand, withCopyFileToContainer, withCreateContainerCmdModifier, withEnv, withEnv, withExposedPorts, withExtraHost, withFileSystemBind, withLabel, withLabels, withLogConsumer, withMinimumRunningDuration, withNetwork, withNetworkAliases, withNetworkMode, withPrivilegedMode, 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

addEnv, addExposedPort, addExposedPorts, addFileSystemBind, addFileSystemBind, addLink, copyFileFromContainer, copyFileFromContainer, copyFileToContainer, copyFileToContainer, execInContainer, execInContainer, fetchDockerDaemonInfo, followOutput, followOutput, getBinds, getCommandParts, getDockerClient, getDockerDaemonInfo, getDockerImageName, getEnv, getEnvMap, getExtraHosts, getImage, getLinkedContainers, getPortBindings, getTestHostIpAddress, self, setBinds, setCommand, setCommand, setCommandParts, setDockerImageName, setEnv, setExposedPorts, setExtraHosts, setImage, setLinkedContainers, setPortBindings, setWaitStrategy, waitingFor, withClasspathResourceMapping, withClasspathResourceMapping, withCommand, withCommand, withCopyFileToContainer, withEnv, withEnv, withEnv, withExposedPorts, withExtraHost, withFileSystemBind, withFileSystemBind, withLabel, withLabels, withLogConsumer, withMinimumRunningDuration, withNetwork, withNetworkAliases, withNetworkMode, withPrivilegedMode, withStartupCheckStrategy, withStartupTimeout, withVolumesFrom, withWorkingDirectory

Methods inherited from interface org.testcontainers.containers.traits.LinkableContainer

getContainerName

Methods inherited from interface org.testcontainers.containers.ContainerState

getBoundPortNumbers, getContainerId, getContainerInfo, getContainerIpAddress, getCurrentContainerInfo, getExposedPorts, getFirstMappedPort, getLogs, getLogs, getMappedPort, isCreated, isHealthy, isRunning

Methods inherited from interface org.testcontainers.lifecycle.Startable

close

Field Detail

GROUP_ID_CONFIG

public static final String GROUP_ID_CONFIG

Key / value for Configuration

See Also:

Constant Field Values

OFFSET_STORAGE_FILE_FILENAME_CONFIG

public static final String OFFSET_STORAGE_FILE_FILENAME_CONFIG

See Also:

Constant Field Values

OFFSET_STORAGE_TOPIC_CONFIG

public static final String OFFSET_STORAGE_TOPIC_CONFIG

See Also:

Constant Field Values

OFFSET_STORAGE_PARTITIONS_CONFIG

public static final String OFFSET_STORAGE_PARTITIONS_CONFIG

See Also:

Constant Field Values

CONFIG_STORAGE_TOPIC_CONFIG

public static final String CONFIG_STORAGE_TOPIC_CONFIG

See Also:

Constant Field Values

STATUS_STORAGE_TOPIC_CONFIG

public static final String STATUS_STORAGE_TOPIC_CONFIG

See Also:

Constant Field Values

STATUS_STORAGE_PARTITIONS_CONFIG

public static final String STATUS_STORAGE_PARTITIONS_CONFIG

See Also:

Constant Field Values

KEY_CONVERTER_CONFIG

public static final String KEY_CONVERTER_CONFIG

See Also:

Constant Field Values

KEY_CONVERTER_SCHEMA_REGISTRY_URL_CONFIG

public static final String KEY_CONVERTER_SCHEMA_REGISTRY_URL_CONFIG

See Also:

Constant Field Values

VALUE_CONVERTER_CONFIG

public static final String VALUE_CONVERTER_CONFIG

See Also:

Constant Field Values

VALUE_CONVERTER_SCHEMA_REGISTRY_URL_CONFIG

public static final String VALUE_CONVERTER_SCHEMA_REGISTRY_URL_CONFIG

See Also:

Constant Field Values

Constructor Detail

KafkaConnectContainer

public KafkaConnectContainer(String version)

Parameters:

version -

KafkaConnectContainer

public KafkaConnectContainer(String version,
                             int restAppMappingPort)

Parameters:

version -

restAppMappingPort -

Method Detail

withBrokersServerUrl

public KafkaConnectContainer withBrokersServerUrl(String brokersServerUrl)

withSchemaRegistryUrl

public KafkaConnectContainer withSchemaRegistryUrl(String schemaRegistryUrl)

configure

protected void configure()

Configure de the container

Overrides:

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

withServerCertificates

public KafkaConnectContainer withServerCertificates(Certificates certificates)

Parameters:

certificates -

Returns:

start

public void start()

Start the container

Specified by:

start in interface org.testcontainers.lifecycle.Startable

Overrides:

start in class org.testcontainers.containers.GenericContainer<KafkaConnectContainer>

withGroupId

public KafkaConnectContainer withGroupId(String groupId)

Set the group id

Parameters:

groupId -

Returns:

withConfigStorageTopic

public KafkaConnectContainer withConfigStorageTopic(String topic)

Set the config storage topic.

Parameters:

topic -

Returns:

withOffsetStorageTopic

public KafkaConnectContainer withOffsetStorageTopic(String topic)

Set the topic name of the storage offsets topic.

Parameters:

topic -

Returns:

withOffsetStoragePartition

public KafkaConnectContainer withOffsetStoragePartition(Integer partitions)

Set the offsets storage partition.

Parameters:

partitions -

Returns:

withStatusStorageTopic

public KafkaConnectContainer withStatusStorageTopic(String topic)

Set the status storage topic's name.

Parameters:

topic -

Returns:

withStatusStoragePartition

public KafkaConnectContainer withStatusStoragePartition(Integer partitions)

Set the status storage partition.

Parameters:

partitions -

Returns:

withOffsetStorageFilename

public KafkaConnectContainer withOffsetStorageFilename(String storageFilename)

Set the offsets storage file name.

Parameters:

storageFilename -

Returns:

withKeyConverter

public KafkaConnectContainer withKeyConverter(String keyConverter)

Set the key converter.

Parameters:

keyConverter -

Returns:

withValueConverter

public KafkaConnectContainer withValueConverter(String valueConverter)

Set the value converter.

Parameters:

valueConverter -

Returns:

withPlugins

public KafkaConnectContainer withPlugins(Set<String> plugins)

Set the list of plugins directory.

Parameters:

plugins -

Returns:

withPlugins

public KafkaConnectContainer withPlugins(String plugins)

Set the plugins directory.

Parameters:

plugins -

Returns:

withRestAppSystemProperty

public KafkaConnectContainer withRestAppSystemProperty(String restAppSystemProperty)

Parameters:

restAppSystemProperty -

Returns:

withRegisterSpringbootProperties

public KafkaConnectContainer withRegisterSpringbootProperties(boolean registerProperties)

Set if the sytem properties must be registred.

Specified by:

withRegisterSpringbootProperties in interface IContainer<KafkaConnectContainer>

Parameters:

registerProperties -

Returns:

registerSpringbootProperties

public boolean registerSpringbootProperties()

Check if system properties must be registred.

Specified by:

registerSpringbootProperties in interface IContainer<KafkaConnectContainer>

Returns:

getURL

public String getURL()

Get the url.

Specified by:

getURL in interface IContainer<KafkaConnectContainer>

Returns:

getInternalURL

public String getInternalURL()

Get the local url

Specified by:

getInternalURL in interface IContainer<KafkaConnectContainer>

Returns:

registerKafkaConnectEnvironment

protected void registerKafkaConnectEnvironment()

Register system properties.

equals

public boolean equals(Object o)

Overrides:

equals in class org.testcontainers.containers.GenericContainer<KafkaConnectContainer>

hashCode

public int hashCode()

Overrides:

hashCode in class org.testcontainers.containers.GenericContainer<KafkaConnectContainer>