Uses of Class
com.github.ydespreaux.testcontainers.kafka.containers.KafkaConnectContainer

Packages that use KafkaConnectContainer

Package	Description
com.github.ydespreaux.testcontainers.kafka.containers

Uses of KafkaConnectContainer in com.github.ydespreaux.testcontainers.kafka.containers

Methods in com.github.ydespreaux.testcontainers.kafka.containers that return KafkaConnectContainer

Modifier and Type	Method and Description
KafkaConnectContainer	KafkaConnectContainer.withBrokersServerUrl(String brokersServerUrl)
KafkaConnectContainer	KafkaConnectContainer.withConfigStorageTopic(String topic) Set the config storage topic.
KafkaConnectContainer	KafkaConnectContainer.withGroupId(String groupId) Set the group id
KafkaConnectContainer	KafkaConnectContainer.withKeyConverter(String keyConverter) Set the key converter.
KafkaConnectContainer	KafkaConnectContainer.withOffsetStorageFilename(String storageFilename) Set the offsets storage file name.
KafkaConnectContainer	KafkaConnectContainer.withOffsetStoragePartition(Integer partitions) Set the offsets storage partition.
KafkaConnectContainer	KafkaConnectContainer.withOffsetStorageTopic(String topic) Set the topic name of the storage offsets topic.
KafkaConnectContainer	KafkaConnectContainer.withPlugins(Set<String> plugins) Set the list of plugins directory.
KafkaConnectContainer	KafkaConnectContainer.withPlugins(String plugins) Set the plugins directory.
KafkaConnectContainer	KafkaConnectContainer.withRegisterSpringbootProperties(boolean registerProperties) Set if the sytem properties must be registred.
KafkaConnectContainer	KafkaConnectContainer.withRestAppSystemProperty(String restAppSystemProperty)
KafkaConnectContainer	KafkaConnectContainer.withSchemaRegistryUrl(String schemaRegistryUrl)
KafkaConnectContainer	KafkaConnectContainer.withServerCertificates(Certificates certificates)
KafkaConnectContainer	KafkaConnectContainer.withStatusStoragePartition(Integer partitions) Set the status storage partition.
KafkaConnectContainer	KafkaConnectContainer.withStatusStorageTopic(String topic) Set the status storage topic's name.
KafkaConnectContainer	KafkaConnectContainer.withValueConverter(String valueConverter) Set the value converter.