A B C D E G H I K L O R S T U V W Z

A

AclsAddCmd - Class in com.github.ydespreaux.testcontainers.kafka.cmd

AclsAddCmd(Certificates) - Constructor for class com.github.ydespreaux.testcontainers.kafka.cmd.AclsAddCmd

AclsListCmd - Class in com.github.ydespreaux.testcontainers.kafka.cmd

AclsListCmd(String) - Constructor for class com.github.ydespreaux.testcontainers.kafka.cmd.AclsListCmd

AclsListCmd(String, AclsListCmd.ResourceAcls) - Constructor for class com.github.ydespreaux.testcontainers.kafka.cmd.AclsListCmd

AclsListCmd.ResourceAcls - Enum in com.github.ydespreaux.testcontainers.kafka.cmd

AclsOperation - Enum in com.github.ydespreaux.testcontainers.kafka.cmd

after() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

Stop and remove all containers.

afterPropertiesSet() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

afterPropertiesSet() - Method in class com.github.ydespreaux.testcontainers.kafka.security.Certificates

B

before() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

Start all containers.

buildParameters(KafkaContainer) - Method in class com.github.ydespreaux.testcontainers.kafka.cmd.AclsAddCmd

buildParameters(KafkaContainer) - Method in class com.github.ydespreaux.testcontainers.kafka.cmd.AclsListCmd

buildParameters(KafkaContainer) - Method in class com.github.ydespreaux.testcontainers.kafka.cmd.KafkaReadyCmd

buildParameters(KafkaContainer) - Method in class com.github.ydespreaux.testcontainers.kafka.cmd.TopicCreateCommand

buildParameters(KafkaContainer) - Method in class com.github.ydespreaux.testcontainers.kafka.cmd.TopicDescribeCommand

buildParameters(ZookeeperContainer) - Method in class com.github.ydespreaux.testcontainers.kafka.cmd.ZookeeperReadyCmd

C

Certificates - Class in com.github.ydespreaux.testcontainers.kafka.security

Certificates(String, String) - Constructor for class com.github.ydespreaux.testcontainers.kafka.security.Certificates

Certificates(String, String, String, String) - Constructor for class com.github.ydespreaux.testcontainers.kafka.security.Certificates

CertificateUtils - Class in com.github.ydespreaux.testcontainers.kafka.security

cluster(String) - Method in class com.github.ydespreaux.testcontainers.kafka.cmd.AclsAddCmd

com.github.ydespreaux.testcontainers.kafka - package com.github.ydespreaux.testcontainers.kafka

com.github.ydespreaux.testcontainers.kafka.cmd - package com.github.ydespreaux.testcontainers.kafka.cmd

com.github.ydespreaux.testcontainers.kafka.config - package com.github.ydespreaux.testcontainers.kafka.config

com.github.ydespreaux.testcontainers.kafka.containers - package com.github.ydespreaux.testcontainers.kafka.containers

com.github.ydespreaux.testcontainers.kafka.rule - package com.github.ydespreaux.testcontainers.kafka.rule

com.github.ydespreaux.testcontainers.kafka.security - package com.github.ydespreaux.testcontainers.kafka.security

CONFIG_STORAGE_TOPIC_CONFIG - Static variable in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

configure() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Configure de the container

configure() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

Configure the container.

configure() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

Configure the container

configure() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.ZookeeperContainer

Configure the container

ConfluentContainer<S extends ConfluentContainer<S>> - Interface in com.github.ydespreaux.testcontainers.kafka.rule

ConfluentKafkaConnectContainer - Class in com.github.ydespreaux.testcontainers.kafka.rule

Define the environment for kafka connect container.

ConfluentKafkaConnectContainer() - Constructor for class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

ConfluentKafkaConnectContainer(String) - Constructor for class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

ConfluentKafkaContainer<S extends ConfluentKafkaContainer<S>> - Class in com.github.ydespreaux.testcontainers.kafka.rule

This class is used to start a zookeeper container, a kafka container, and a schema registry container if it is enabled.

ConfluentKafkaContainer() - Constructor for class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

ConfluentKafkaContainer(String) - Constructor for class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

D

destroy() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

Destroy all containers.

E

equals(Object) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

equals(Object) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

equals(Object) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

equals(Object) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.ZookeeperContainer

G

generateCredentials(String) - Static method in class com.github.ydespreaux.testcontainers.kafka.security.CertificateUtils

getBootstrapServers() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

Get the kafka url.

getInternalURL() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Get the local url

getInternalURL() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

Get the local url.

getInternalURL() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

Get the local url.

getInternalURL() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.ZookeeperContainer

Get the local url.

getKafkaClientCertificates() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

getKafkaServerCertificates() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

getLocalURL() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

Deprecated.

use getInternalURL()

getRestAppServers() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

Get the url of the rest api.

getSchemaRegistryServers() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

getSubject(KeyStore, String) - Static method in class com.github.ydespreaux.testcontainers.kafka.security.CertificateUtils

getURL() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Get the url.

getURL() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

Get the url.

getURL() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

Get the url.

getURL() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.ZookeeperContainer

Get the url.

getZookeeperConnect() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

Get the local zookeeper url.

getZookeeperServer() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

Get the zookeeper url.

group(String) - Method in class com.github.ydespreaux.testcontainers.kafka.cmd.AclsAddCmd

GROUP_ID_CONFIG - Static variable in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Key / value for Configuration

H

hashCode() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

hashCode() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

hashCode() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

hashCode() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.ZookeeperContainer

I

InvalidCertificateException - Exception in com.github.ydespreaux.testcontainers.kafka.security

InvalidCertificateException(Path, Throwable) - Constructor for exception com.github.ydespreaux.testcontainers.kafka.security.InvalidCertificateException

InvalidCertificateException(Throwable) - Constructor for exception com.github.ydespreaux.testcontainers.kafka.security.InvalidCertificateException

isRunning() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

isSecured() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

isSecured() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

isSecured() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

K

KafkaConnectContainer - Class in com.github.ydespreaux.testcontainers.kafka.containers

Define Kafka connect container.

KafkaConnectContainer(String) - Constructor for class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

KafkaConnectContainer(String, int) - Constructor for class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

KafkaContainer - Class in com.github.ydespreaux.testcontainers.kafka.containers

Kafka container.

KafkaContainer(String) - Constructor for class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

KafkaContainer(String, int) - Constructor for class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

KafkaReadyCmd - Class in com.github.ydespreaux.testcontainers.kafka.cmd

KafkaReadyCmd() - Constructor for class com.github.ydespreaux.testcontainers.kafka.cmd.KafkaReadyCmd

KafkaReadyCmd(int) - Constructor for class com.github.ydespreaux.testcontainers.kafka.cmd.KafkaReadyCmd

KEY_CONVERTER_CONFIG - Static variable in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

KEY_CONVERTER_SCHEMA_REGISTRY_URL_CONFIG - Static variable in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

L

loadKeyStore(Path, String) - Static method in class com.github.ydespreaux.testcontainers.kafka.security.CertificateUtils

O

OFFSET_STORAGE_FILE_FILENAME_CONFIG - Static variable in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

OFFSET_STORAGE_PARTITIONS_CONFIG - Static variable in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

OFFSET_STORAGE_TOPIC_CONFIG - Static variable in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

operation(AclsOperation) - Method in class com.github.ydespreaux.testcontainers.kafka.cmd.AclsAddCmd

operationName() - Method in enum com.github.ydespreaux.testcontainers.kafka.cmd.AclsOperation

R

registerKafkaConnectEnvironment() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Register system properties.

registerKafkaEnvironment() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

Register spring boot properties.

registerSchemaRegistryEnvironment() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

Register the spring boot properties.

registerSpringbootProperties() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Check if system properties must be registred.

registerSpringbootProperties() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

registerSpringbootProperties() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

registerSpringbootProperties() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.ZookeeperContainer

resourceName() - Method in enum com.github.ydespreaux.testcontainers.kafka.cmd.AclsListCmd.ResourceAcls

S

SchemaRegistryContainer - Class in com.github.ydespreaux.testcontainers.kafka.containers

Schema registry container.

SchemaRegistryContainer(String) - Constructor for class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

SchemaRegistryContainer(String, int) - Constructor for class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

self() - Method in interface com.github.ydespreaux.testcontainers.kafka.rule.ConfluentContainer

self() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

start() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Start the container

start() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

start the container.

start() - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

Start the container.

start() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

Start all containers.

start() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

STATUS_STORAGE_PARTITIONS_CONFIG - Static variable in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

STATUS_STORAGE_TOPIC_CONFIG - Static variable in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

stop() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

Destroy all containers.

stop() - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

T

topic(String) - Method in class com.github.ydespreaux.testcontainers.kafka.cmd.AclsAddCmd

TopicConfiguration - Class in com.github.ydespreaux.testcontainers.kafka.config

TopicConfiguration() - Constructor for class com.github.ydespreaux.testcontainers.kafka.config.TopicConfiguration

TopicCreateCommand - Class in com.github.ydespreaux.testcontainers.kafka.cmd

TopicCreateCommand(TopicConfiguration) - Constructor for class com.github.ydespreaux.testcontainers.kafka.cmd.TopicCreateCommand

TopicDescribeCommand - Class in com.github.ydespreaux.testcontainers.kafka.cmd

TopicDescribeCommand(String) - Constructor for class com.github.ydespreaux.testcontainers.kafka.cmd.TopicDescribeCommand

U

user(String) - Method in class com.github.ydespreaux.testcontainers.kafka.cmd.AclsAddCmd

V

VALUE_CONVERTER_CONFIG - Static variable in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

VALUE_CONVERTER_SCHEMA_REGISTRY_URL_CONFIG - Static variable in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

valueOf(String) - Static method in enum com.github.ydespreaux.testcontainers.kafka.cmd.AclsListCmd.ResourceAcls

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.github.ydespreaux.testcontainers.kafka.cmd.AclsOperation

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.github.ydespreaux.testcontainers.kafka.cmd.AclsListCmd.ResourceAcls

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.github.ydespreaux.testcontainers.kafka.cmd.AclsOperation

Returns an array containing the constants of this enum type, in the order they are declared.

W

withAcls(List<AclsAddCmd>) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withAcls(AclsOperation, String, String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withAcls(Certificates, AclsOperation, String, String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withAcls(AclsOperation[], String, String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withAcls(Certificates, AclsOperation[], String, String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withAllAcls(String, String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withAllAcls(Certificates, String, String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withBootstrapServersInternalURL(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

Set bootstrap servers for local container.

withBrokerServersSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withBrokerServersSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withBrokersServerUrl(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

withConfigStorageTopic(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Set the config storage topic.

withConfigStorageTopic(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

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

withDescribeAcls(String, String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withDescribeAcls(Certificates, String, String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withFormatMessageVersion(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

Set of the message compatibility version.

withFormatMessageVersion(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withGroupId(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Set the group id

withGroupId(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

Set the group id.

withIdentificationAlgorithmSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withIdentificationAlgorithmSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withKafkaClientCertificates(Certificates) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withKafkaClientCertificates(Certificates) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withKafkaConnectCertificates(Certificates) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

withKafkaServerCertificates(Certificates) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withKafkaServerCertificates(Certificates) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withKeyConverter(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Set the key converter.

withKeyConverter(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

Set the key converter.

withKeyPasswordSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withKeyPasswordSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withKeystoreLocationSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withKeystoreLocationSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withKeystorePasswordSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withKeystorePasswordSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withNetwork(Network) - Method in interface com.github.ydespreaux.testcontainers.kafka.rule.ConfluentContainer

Set the network

withNetwork(Network) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

Set the network.

withOffsetStorageFilename(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Set the offsets storage file name.

withOffsetStorageFilename(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

Set the storage file name.

withOffsetStoragePartition(Integer) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Set the offsets storage partition.

withOffsetStoragePartition(Integer) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

Set the number of partitions for the offsets storage topic.

withOffsetStorageTopic(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Set the topic name of the storage offsets topic.

withOffsetStorageTopic(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

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

withPlugins(Set<String>) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Set the list of plugins directory.

withPlugins(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Set the plugins directory.

withPlugins(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

Set the plugins directory

withReadAcls(String, String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withReadAcls(Certificates, String, String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withRegisterSpringbootProperties(boolean) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Set if the sytem properties must be registred.

withRegisterSpringbootProperties(boolean) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withRegisterSpringbootProperties(boolean) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

withRegisterSpringbootProperties(boolean) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.ZookeeperContainer

withRegisterSpringbootProperties(boolean) - Method in interface com.github.ydespreaux.testcontainers.kafka.rule.ConfluentContainer

Set if the spring boot properties must be registred.

withRegisterSpringbootProperties(boolean) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

Register the spring boot properties.

withRegisterSpringbootProperties(boolean) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

Register the spring boot properties.

withRestAppSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

withRestAppSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

Set the property 's name for schema registry url.

withSchemaRegistry(boolean) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

Enable the schema registry.

withSchemaRegistrySystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

withSchemaRegistrySystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withSchemaRegistryUrl(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

withSecurityProtocolSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withSecurityProtocolSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withServerCertificates(Certificates) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

withServerCertificates(Certificates) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

withStatusStoragePartition(Integer) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Set the status storage partition.

withStatusStoragePartition(Integer) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

Set the number of partitions for the status storage topic.

withStatusStorageTopic(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Set the status storage topic's name.

withStatusStorageTopic(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

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

withTopic(String, int, boolean) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withTopic(TopicConfiguration) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withTopics(List<TopicConfiguration>) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withTruststoreLocationSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withTruststoreLocationSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withTruststorePasswordSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withTruststorePasswordSystemProperty(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withValueConverter(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Set the value converter.

withValueConverter(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

Set the value converter.

withWriteAcls(String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withWriteAcls(Certificates, String) - Method in class com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaContainer

withZookeeperHostname(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

withZookeeperInternalURL(String) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.SchemaRegistryContainer

Set the zookeeper url for local container.

withZookeeperPort(Integer) - Method in class com.github.ydespreaux.testcontainers.kafka.containers.KafkaContainer

Set the zookeeper port.

Z

ZookeeperContainer - Class in com.github.ydespreaux.testcontainers.kafka.containers

Zookeeper container.

ZookeeperContainer(String) - Constructor for class com.github.ydespreaux.testcontainers.kafka.containers.ZookeeperContainer

ZookeeperContainer(String, int) - Constructor for class com.github.ydespreaux.testcontainers.kafka.containers.ZookeeperContainer

ZookeeperReadyCmd - Class in com.github.ydespreaux.testcontainers.kafka.cmd

ZookeeperReadyCmd() - Constructor for class com.github.ydespreaux.testcontainers.kafka.cmd.ZookeeperReadyCmd

ZookeeperReadyCmd(int) - Constructor for class com.github.ydespreaux.testcontainers.kafka.cmd.ZookeeperReadyCmd

A B C D E G H I K L O R S T U V W Z