Uses of Class
com.github.ydespreaux.testcontainers.kafka.rule.ConfluentKafkaConnectContainer

Packages that use ConfluentKafkaConnectContainer

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

Uses of ConfluentKafkaConnectContainer in com.github.ydespreaux.testcontainers.kafka.rule

Methods in com.github.ydespreaux.testcontainers.kafka.rule that return ConfluentKafkaConnectContainer

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