com.github.ydespreaux.testcontainers.kafka.rule

Class ConfluentKafkaConnectContainer

java.lang.Object

org.junit.rules.ExternalResource

com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer<ConfluentKafkaConnectContainer>

com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

All Implemented Interfaces:

ConfluentContainer<ConfluentKafkaConnectContainer>, AutoCloseable, org.junit.rules.TestRule, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.testcontainers.lifecycle.Startable

public class ConfluentKafkaConnectContainer
extends ConfluentKafkaContainer<ConfluentKafkaConnectContainer>

Define the environment for kafka connect container. This class is used to start a zookeeper container, a kafka container, a schema registry container if it is enabled, and a kafka connect container.

Since:

1.0.0

Author:

Yoann Despréaux

Constructor Summary

Constructors

Constructor and Description
ConfluentKafkaConnectContainer()
ConfluentKafkaConnectContainer(String confluentVersion)

Method Summary

Modifier and Type	Method and Description
String	getRestAppServers() Get the url of the rest api.
void	start() Start all containers.
void	stop() Destroy all containers.
ConfluentKafkaConnectContainer	withConfigStorageTopic(String topic) Set the topic's name for the offsets storage topic.
ConfluentKafkaConnectContainer	withGroupId(String groupId) Set the group id.
ConfluentKafkaConnectContainer	withKafkaConnectCertificates(Certificates certificates)
ConfluentKafkaConnectContainer	withKeyConverter(String keyConverter) Set the key converter.
ConfluentKafkaConnectContainer	withOffsetStorageFilename(String storageFilename) Set the storage file name.
ConfluentKafkaConnectContainer	withOffsetStoragePartition(Integer partitions) Set the number of partitions for the offsets storage topic.
ConfluentKafkaConnectContainer	withOffsetStorageTopic(String topic) Set the topic's name for the offsets storage topic.
ConfluentKafkaConnectContainer	withPlugins(String plugins) Set the plugins directory
ConfluentKafkaConnectContainer	withRegisterSpringbootProperties(boolean registerProperties) Register the spring boot properties.
ConfluentKafkaConnectContainer	withRestAppSystemProperty(String restAppSystemProperty) Set the property 's name for schema registry url.
ConfluentKafkaConnectContainer	withStatusStoragePartition(Integer partitions) Set the number of partitions for the status storage topic.
ConfluentKafkaConnectContainer	withStatusStorageTopic(String topic) Set the topic's name for the status storage topic.
ConfluentKafkaConnectContainer	withValueConverter(String valueConverter) Set the value converter.

Methods inherited from class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

after, afterPropertiesSet, before, destroy, getBootstrapServers, getKafkaClientCertificates, getKafkaServerCertificates, getSchemaRegistryServers, getZookeeperConnect, getZookeeperServer, isRunning, isSecured, self, withAcls, withAcls, withAcls, withAcls, withAllAcls, withAllAcls, withBrokerServersSystemProperty, withDescribeAcls, withDescribeAcls, withFormatMessageVersion, withIdentificationAlgorithmSystemProperty, withKafkaClientCertificates, withKafkaServerCertificates, withKeyPasswordSystemProperty, withKeystoreLocationSystemProperty, withKeystorePasswordSystemProperty, withNetwork, withReadAcls, withReadAcls, withSchemaRegistry, withSchemaRegistrySystemProperty, withSecurityProtocolSystemProperty, withTopic, withTopic, withTruststoreLocationSystemProperty, withTruststorePasswordSystemProperty, withWriteAcls, withWriteAcls

Methods inherited from class org.junit.rules.ExternalResource

apply

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.junit.rules.TestRule

apply

Methods inherited from interface org.testcontainers.lifecycle.Startable

close

Constructor Detail

ConfluentKafkaConnectContainer

public ConfluentKafkaConnectContainer()

ConfluentKafkaConnectContainer

public ConfluentKafkaConnectContainer(String confluentVersion)

Parameters:

confluentVersion -

Method Detail

start

public void start()

Start all containers.

Specified by:

start in interface org.testcontainers.lifecycle.Startable

Overrides:

start in class ConfluentKafkaContainer<ConfluentKafkaConnectContainer>

stop

public void stop()

Destroy all containers.

Specified by:

stop in interface org.testcontainers.lifecycle.Startable

Overrides:

stop in class ConfluentKafkaContainer<ConfluentKafkaConnectContainer>

withRegisterSpringbootProperties

public ConfluentKafkaConnectContainer withRegisterSpringbootProperties(boolean registerProperties)

Register the spring boot properties.

Specified by:

withRegisterSpringbootProperties in interface ConfluentContainer<ConfluentKafkaConnectContainer>

Overrides:

withRegisterSpringbootProperties in class ConfluentKafkaContainer<ConfluentKafkaConnectContainer>

Parameters:

registerProperties -

Returns:

withKafkaConnectCertificates

public ConfluentKafkaConnectContainer withKafkaConnectCertificates(Certificates certificates)

Parameters:

certificates -

Returns:

getRestAppServers

public String getRestAppServers()

Get the url of the rest api.

Returns:

withGroupId

public ConfluentKafkaConnectContainer withGroupId(String groupId)

Set the group id.

Parameters:

groupId -

Returns:

withConfigStorageTopic

public ConfluentKafkaConnectContainer withConfigStorageTopic(String topic)

Set the topic's name for the offsets storage topic.

Parameters:

topic -

Returns:

withOffsetStorageTopic

public ConfluentKafkaConnectContainer withOffsetStorageTopic(String topic)

Set the topic's name for the offsets storage topic.

Parameters:

topic -

Returns:

withOffsetStoragePartition

public ConfluentKafkaConnectContainer withOffsetStoragePartition(Integer partitions)

Set the number of partitions for the offsets storage topic.

Parameters:

partitions -

Returns:

withStatusStorageTopic

public ConfluentKafkaConnectContainer withStatusStorageTopic(String topic)

Set the topic's name for the status storage topic.

Parameters:

topic -

Returns:

withStatusStoragePartition

public ConfluentKafkaConnectContainer withStatusStoragePartition(Integer partitions)

Set the number of partitions for the status storage topic.

Parameters:

partitions -

Returns:

withOffsetStorageFilename

public ConfluentKafkaConnectContainer withOffsetStorageFilename(String storageFilename)

Set the storage file name.

Parameters:

storageFilename -

Returns:

withKeyConverter

public ConfluentKafkaConnectContainer withKeyConverter(String keyConverter)

Set the key converter.

Parameters:

keyConverter -

Returns:

withValueConverter

public ConfluentKafkaConnectContainer withValueConverter(String valueConverter)

Set the value converter.

Parameters:

valueConverter -

Returns:

withPlugins

public ConfluentKafkaConnectContainer withPlugins(String plugins)

Set the plugins directory

Parameters:

plugins -

Returns:

withRestAppSystemProperty

public ConfluentKafkaConnectContainer withRestAppSystemProperty(String restAppSystemProperty)

Set the property 's name for schema registry url.

Parameters:

restAppSystemProperty -

Returns: