From d63c25e3173de78b34426af19416d72035fdcdf7 Mon Sep 17 00:00:00 2001 From: Alexandr Nezboretskiy <88882353+anezboretskiy@users.noreply.github.com> Date: Fri, 19 Aug 2022 19:38:35 +0300 Subject: [PATCH] Delete of Steps package #2433 (#2466) Co-authored-by: anezboretskiy Co-authored-by: Vlad Senyuta <66071557+VladSenyuta@users.noreply.github.com> --- .../com/provectus/kafka/ui/steps/Steps.java | 12 ---- .../kafka/ui/steps/kafka/KafkaSteps.java | 62 ------------------- 2 files changed, 74 deletions(-) delete mode 100644 kafka-ui-e2e-checks/src/test/java/com/provectus/kafka/ui/steps/Steps.java delete mode 100644 kafka-ui-e2e-checks/src/test/java/com/provectus/kafka/ui/steps/kafka/KafkaSteps.java diff --git a/kafka-ui-e2e-checks/src/test/java/com/provectus/kafka/ui/steps/Steps.java b/kafka-ui-e2e-checks/src/test/java/com/provectus/kafka/ui/steps/Steps.java deleted file mode 100644 index 2f3fae81a9..0000000000 --- a/kafka-ui-e2e-checks/src/test/java/com/provectus/kafka/ui/steps/Steps.java +++ /dev/null @@ -1,12 +0,0 @@ -package com.provectus.kafka.ui.steps; - -import com.provectus.kafka.ui.steps.kafka.KafkaSteps; - -public class Steps { - - public static final Steps INSTANCE = new Steps(); - - private Steps(){} - - public KafkaSteps kafka = new KafkaSteps(); -} diff --git a/kafka-ui-e2e-checks/src/test/java/com/provectus/kafka/ui/steps/kafka/KafkaSteps.java b/kafka-ui-e2e-checks/src/test/java/com/provectus/kafka/ui/steps/kafka/KafkaSteps.java deleted file mode 100644 index ccaaa19b80..0000000000 --- a/kafka-ui-e2e-checks/src/test/java/com/provectus/kafka/ui/steps/kafka/KafkaSteps.java +++ /dev/null @@ -1,62 +0,0 @@ -package com.provectus.kafka.ui.steps.kafka; - -import lombok.SneakyThrows; -import org.apache.kafka.clients.admin.*; - -import java.util.Collections; -import java.util.HashMap; -import java.util.Map; - -import static org.junit.jupiter.api.Assertions.assertTrue; - -public class KafkaSteps { - - int partitions = 2; - short replicationFactor = 1; - public enum Cluster{ - SECOND_LOCAL("secondLocal","localhost:9093"),LOCAL("local","localhost:9092"); - private String name; - private String server; - private Map config = new HashMap<>(); - Cluster(String name,String server) { - this.name = name; - this.server = server; - this.config.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, server); - this.config.put(AdminClientConfig.REQUEST_TIMEOUT_MS_CONFIG, "5000"); - } - - public String getName() { - return name; - } - } - - - @SneakyThrows - public void createTopic(Cluster cluster,String topicName) { - try (AdminClient client = AdminClient.create(cluster.config)) { - client - .createTopics( - Collections.singleton(new NewTopic(topicName, partitions, replicationFactor)), - new CreateTopicsOptions().timeoutMs(1000)) - .all() - .get(); - - assertTrue(client - .listTopics() - .names().get().contains(topicName)); - - } - } - - @SneakyThrows - public void deleteTopic(Cluster cluster,String topicName) { - try (AdminClient client = AdminClient.create(cluster.config)) { - assertTrue(client.listTopics().names().get().contains(topicName)); - client - .deleteTopics( - Collections.singleton(topicName), new DeleteTopicsOptions().timeoutMs(1000)) - .all() - .get(); - } - } -}