Skip to content

Commit

Permalink
[ST] Update test-clients to 0.9.0 (#10401)
Browse files Browse the repository at this point in the history
Signed-off-by: Lukas Kral <lukywill16@gmail.com>
  • Loading branch information
im-konge authored Aug 5, 2024
1 parent 66ef8d5 commit 287f215
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -208,9 +208,8 @@ public class Environment {
private static final String RESOURCE_ALLOCATION_STRATEGY_DEFAULT = "SHARE_MEMORY_FOR_ALL_COMPONENTS";

private static final String ST_KAFKA_VERSION_DEFAULT = TestKafkaVersion.getDefaultSupportedKafkaVersion();
private static final String ST_CLIENTS_KAFKA_VERSION_DEFAULT = "3.7.0";
// TODO - remove overridden version from TieredStorageST - see TODO in the class
public static final String TEST_CLIENTS_VERSION_DEFAULT = "0.8.1";
private static final String ST_CLIENTS_KAFKA_VERSION_DEFAULT = "3.8.0";
public static final String TEST_CLIENTS_VERSION_DEFAULT = "0.9.0";
public static final String ST_FILE_PLUGIN_URL_DEFAULT = "https://repo1.maven.org/maven2/org/apache/kafka/connect-file/" + ST_KAFKA_VERSION_DEFAULT + "/connect-file-" + ST_KAFKA_VERSION_DEFAULT + ".jar";
public static final String OLM_OPERATOR_VERSION_DEFAULT = "0.42.0";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -262,7 +262,7 @@ void testBuildWithJarTgzAndZip() {

String connectPodName = kubeClient(testStorage.getNamespaceName()).listPodNamesInSpecificNamespace(testStorage.getNamespaceName(), Labels.STRIMZI_KIND_LABEL, KafkaConnect.RESOURCE_KIND).stream()
.filter(it -> it.contains(testStorage.getClusterName())).toList().get(0);
PodUtils.waitUntilMessageIsInPodLogs(testStorage.getNamespaceName(), connectPodName, "Received message with key 'null' and value '\"Hello-world - 99\"'");
PodUtils.waitUntilMessageIsInPodLogs(testStorage.getNamespaceName(), connectPodName, "Received message with key 'null' and value 'Hello-world - 99'");
}

@OpenShiftOnly
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -156,18 +156,7 @@ void testTieredStorageWithAivenPlugin() {
testStorage.getNamespaceName(),
testStorage.getAdminName(),
KafkaResources.plainBootstrapAddress(testStorage.getClusterName())
)
.editSpec()
.editOrNewTemplate()
.editSpec()
.editFirstContainer()
// TODO - remove this when new version of clients will be available
.withImage("quay.io/strimzi-test-clients/test-clients:latest-kafka-" + Environment.ST_KAFKA_VERSION)
.endContainer()
.endSpec()
.endTemplate()
.endSpec()
.build()
).build()
);
final AdminClient adminClient = AdminClientUtils.getConfiguredAdminClient(testStorage.getNamespaceName(), testStorage.getAdminName());

Expand Down

0 comments on commit 287f215

Please sign in to comment.