From bd59d2dd2891a2d7f532c859525ebcca4cbf198d Mon Sep 17 00:00:00 2001
From: Lukas Kral <lukywill16@gmail.com>
Date: Wed, 4 Dec 2024 10:19:43 +0100
Subject: [PATCH] [ST] Add check for passing the ConfigMap field to env
 variable using Connect Container template

Signed-off-by: Lukas Kral <lukywill16@gmail.com>
---
 .../systemtest/kafka/ConfigProviderST.java    | 20 ++++++++++++++-----
 1 file changed, 15 insertions(+), 5 deletions(-)

diff --git a/systemtest/src/test/java/io/strimzi/systemtest/kafka/ConfigProviderST.java b/systemtest/src/test/java/io/strimzi/systemtest/kafka/ConfigProviderST.java
index 76725d063b6..3a9b304c487 100644
--- a/systemtest/src/test/java/io/strimzi/systemtest/kafka/ConfigProviderST.java
+++ b/systemtest/src/test/java/io/strimzi/systemtest/kafka/ConfigProviderST.java
@@ -118,12 +118,22 @@ void testConnectWithConnectorUsingConfigAndEnvProvider() {
                 .addToConfig("config.providers.env.class", "org.apache.kafka.common.config.provider.EnvVarConfigProvider")
                 .editOrNewExternalConfiguration()
                     .addNewEnv()
-                .withName("FILE_SINK_FILE")
-                .withNewValueFrom()
-                    .withNewConfigMapKeyRef("file", cmName, false)
-                .endValueFrom()
+                        .withName("FILE_SINK_FILE")
+                        .withNewValueFrom()
+                            .withNewConfigMapKeyRef("file", cmName, false)
+                        .endValueFrom()
                     .endEnv()
                 .endExternalConfiguration()
+                .editOrNewTemplate()
+                    .editOrNewConnectContainer()
+                        .addNewEnv()
+                            .withName("FILE_SINK_TOPICS")
+                            .withNewValueFrom()
+                                .withNewConfigMapKeyRef("topics", cmName, false)
+                            .endValueFrom()
+                        .endEnv()
+                    .endConnectContainer()
+                .endTemplate()
             .endSpec()
             .build());
 
@@ -174,7 +184,7 @@ void testConnectWithConnectorUsingConfigAndEnvProvider() {
                 .addToConfig("file", "${env:FILE_SINK_FILE}")
                 .addToConfig("key.converter", "${" + configPrefix + "key}")
                 .addToConfig("value.converter", "${" + configPrefix + "value}")
-                .addToConfig("topics", "${" + configPrefix + "topics}")
+                .addToConfig("topics", "${env:FILE_SINK_TOPICS}")
             .endSpec()
             .build());