test: clean up state

Author: yeikel

api/pom.xml

@@ -155,6 +155,13 @@
             <artifactId>testcontainers</artifactId>
             <scope>test</scope>
         </dependency>
+
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
         <dependency>
             <groupId>org.testcontainers</groupId>
             <artifactId>kafka</artifactId>

api/src/test/java/io/kafbat/ui/AbstractIntegrationTest.java

@@ -12,13 +12,16 @@
 import org.apache.kafka.clients.admin.AdminClientConfig;
 import org.apache.kafka.clients.admin.NewTopic;
 import org.jetbrains.annotations.NotNull;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.function.ThrowingConsumer;
 import org.junit.jupiter.api.io.TempDir;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.autoconfigure.web.reactive.AutoConfigureWebTestClient;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.context.ApplicationContextInitializer;
 import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.test.annotation.DirtiesContext;
 import org.springframework.test.context.ActiveProfiles;
 import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.util.TestSocketUtils;
@@ -63,16 +66,14 @@ public abstract class AbstractIntegrationTest {
   @TempDir
   public static Path tmpDir;
 
-  static {
-    kafka.start();
-    schemaRegistry.start();
-    kafkaConnect.start();
-  }
-
   public static class Initializer
       implements ApplicationContextInitializer<ConfigurableApplicationContext> {
     @Override
     public void initialize(@NotNull ConfigurableApplicationContext context) {
+      kafka.start();
+      schemaRegistry.start();
+      kafkaConnect.start();
+
       System.setProperty("kafka.clusters.0.name", LOCAL);
       System.setProperty("kafka.clusters.0.bootstrapServers", kafka.getBootstrapServers());
       // List unavailable hosts to verify failover

api/src/test/java/io/kafbat/ui/KafkaConnectServiceTests.java

@@ -24,9 +24,11 @@
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.core.ParameterizedTypeReference;
+import org.springframework.test.annotation.DirtiesContext;
 import org.springframework.test.web.reactive.server.WebTestClient;
 
 @Slf4j
+@DirtiesContext(classMode = DirtiesContext.ClassMode.BEFORE_EACH_TEST_METHOD)
 public class KafkaConnectServiceTests extends AbstractIntegrationTest {
   private final String connectName = "kafka-connect";
   private final String connectorName = UUID.randomUUID().toString();
@@ -42,6 +44,13 @@ public class KafkaConnectServiceTests extends AbstractIntegrationTest {
   @Autowired
   private WebTestClient webTestClient;
 
+  @AfterEach
+  void afterEach() {
+    kafka.stop();
+    schemaRegistry.stop();
+    kafkaConnect.stop();
+  }
+
 
   @BeforeEach
   public void setUp() {