From 2af858135821bdfb4639c209dcdcab20ccd86bb9 Mon Sep 17 00:00:00 2001 From: Jakub Stejskal Date: Tue, 18 Feb 2025 13:52:57 +0100 Subject: [PATCH] Remove KafkaTopic check for worker-02 as it is no longer valid Signed-off-by: Jakub Stejskal --- pom.xml | 8 ++-- .../worker02/status/TopicStatusTest.java | 38 ------------------- 2 files changed, 4 insertions(+), 42 deletions(-) delete mode 100644 src/test/java/io/tealc/worker02/status/TopicStatusTest.java diff --git a/pom.xml b/pom.xml index 64ff5c4..215fcb3 100644 --- a/pom.xml +++ b/pom.xml @@ -15,13 +15,13 @@ 3.2.5 3.2.5 10.9.2 - 4.7.3 - 6.10.0 + 4.9.1 + 7.1.0 2.2 - 5.10.2 + 5.11.4 1.7.33 3.1.2 - 0.43.0 + 0.45.0 1.18.24 0.93.1 1.4.12 diff --git a/src/test/java/io/tealc/worker02/status/TopicStatusTest.java b/src/test/java/io/tealc/worker02/status/TopicStatusTest.java deleted file mode 100644 index 6311951..0000000 --- a/src/test/java/io/tealc/worker02/status/TopicStatusTest.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * Copyright Tealc authors. - * License: Apache License 2.0 (see the file LICENSE or http://apache.org/licenses/LICENSE-2.0.html). - */ -package io.tealc.worker02.status; - -import io.strimzi.api.kafka.model.topic.KafkaTopic; -import io.tealc.Abstract; -import io.tealc.ClusterManager; -import io.tealc.EClusters; -import io.tealc.ENamespaces; -import org.junit.jupiter.params.ParameterizedTest; -import org.junit.jupiter.params.provider.MethodSource; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.util.stream.Stream; - -import static org.hamcrest.CoreMatchers.is; -import static org.hamcrest.MatcherAssert.assertThat; - -public class TopicStatusTest extends Abstract { - - private static final Logger LOGGER = LoggerFactory.getLogger(TopicStatusTest.class); - - @ParameterizedTest(name = "testKafkaTopicIsReady - {0}") - @MethodSource("getTopicNames") - void testKafkaUserIsReady(String topicName) { - KafkaTopic kafkaTopic = ClusterManager.getInstance().getClient(EClusters.WORKER_02).kafkaTopicClient().inNamespace(ENamespaces.KAFKA.name).withName(topicName).get(); - String status = kafkaTopic.getStatus().getConditions().stream().filter(item -> item.getType().equals("Ready")).toList().get(0).getStatus(); - LOGGER.debug("KafkaTopic: {}", kafkaTopic); - assertThat(String.format("KafkaTopic %s is not ready in namespace %s", kafkaTopic.getMetadata().getName(), ENamespaces.KAFKA.name), status, is("True")); - } - - private Stream getTopicNames() { - return ClusterManager.getInstance().getClient(EClusters.WORKER_02).kafkaTopicClient().inNamespace(ENamespaces.KAFKA.name).list().getItems().stream().map(name -> name.getMetadata().getName()).toList().stream(); - } -}