diff --git a/systemtest/src/test/java/io/strimzi/systemtest/connect/ConnectST.java b/systemtest/src/test/java/io/strimzi/systemtest/connect/ConnectST.java index b835692637c..3eaf1d07fe7 100644 --- a/systemtest/src/test/java/io/strimzi/systemtest/connect/ConnectST.java +++ b/systemtest/src/test/java/io/strimzi/systemtest/connect/ConnectST.java @@ -867,7 +867,7 @@ void testConnectTlsAuthWithWeirdUserName() { .addToConfig("value.converter", "org.apache.kafka.connect.storage.StringConverter") .withNewTls() .withTrustedCertificates(new CertSecretSourceBuilder() - .withCertificate("ca.crt") + .withPattern("*.crt") .withSecretName(KafkaResources.clusterCaCertificateSecretName(testStorage.getClusterName())) .build()) .endTls() diff --git a/systemtest/src/test/java/io/strimzi/systemtest/mirrormaker/MirrorMaker2ST.java b/systemtest/src/test/java/io/strimzi/systemtest/mirrormaker/MirrorMaker2ST.java index 8f3a5776d96..f889b80fecb 100644 --- a/systemtest/src/test/java/io/strimzi/systemtest/mirrormaker/MirrorMaker2ST.java +++ b/systemtest/src/test/java/io/strimzi/systemtest/mirrormaker/MirrorMaker2ST.java @@ -1008,9 +1008,9 @@ void testKMM2RollAfterSecretsCertsUpdateScramSha() { certSecretSource.setCertificate("ca.crt"); certSecretSource.setSecretName(KafkaResources.clusterCaCertificateSecretName(testStorage.getSourceClusterName())); - // Initialize CertSecretSource with certificate and secret names for target + // Initialize CertSecretSource with certificate and secret names for target (using pattern) CertSecretSource certSecretTarget = new CertSecretSource(); - certSecretTarget.setCertificate("ca.crt"); + certSecretTarget.setPattern("*.crt"); certSecretTarget.setSecretName(KafkaResources.clusterCaCertificateSecretName(testStorage.getTargetClusterName())); resourceManager.createResourceWithWait(KafkaMirrorMaker2Templates.kafkaMirrorMaker2(testStorage, 1, true) diff --git a/systemtest/src/test/java/io/strimzi/systemtest/security/oauth/OauthTlsST.java b/systemtest/src/test/java/io/strimzi/systemtest/security/oauth/OauthTlsST.java index 4c63843a980..c77c9248fd0 100644 --- a/systemtest/src/test/java/io/strimzi/systemtest/security/oauth/OauthTlsST.java +++ b/systemtest/src/test/java/io/strimzi/systemtest/security/oauth/OauthTlsST.java @@ -516,10 +516,10 @@ void testMirrorMaker2() { .withAlias(testStorage.getTargetClusterName()) .withConfig(connectorConfig) .withBootstrapServers(KafkaResources.tlsBootstrapAddress(targetKafkaCluster)) - // this is for kafka tls connection + // this is for kafka tls connection (using pattern) .withNewTls() .withTrustedCertificates(new CertSecretSourceBuilder() - .withCertificate("ca.crt") + .withPattern("*.crt") .withSecretName(KafkaResources.clusterCaCertificateSecretName(targetKafkaCluster)) .build()) .endTls()