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;
@@ -31,6 +34,7 @@
 @ActiveProfiles("test")
 @AutoConfigureWebTestClient(timeout = "60000")
 @ContextConfiguration(initializers = {AbstractIntegrationTest.Initializer.class})
+@DirtiesContext(classMode = DirtiesContext.ClassMode.BEFORE_EACH_TEST_METHOD)
 public abstract class AbstractIntegrationTest {
   public static final String LOCAL = "local";
   public static final String SECOND_LOCAL = "secondLocal";
@@ -63,7 +67,15 @@ public abstract class AbstractIntegrationTest {
   @TempDir
   public static Path tmpDir;
 
-  static {
+  @AfterEach
+  void afterEach() {
+    kafka.stop();
+    schemaRegistry.stop();
+    kafkaConnect.stop();
+  }
+
+  @BeforeEach
+  void beforeEach() {
     kafka.start();
     schemaRegistry.start();
     kafkaConnect.start();