stop after class

eo-cqrs · May 22, 2023 · d1b3226 · d1b3226
1 parent 66f9d27
commit d1b3226
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/it/producer-consumer-api/src/test/java/KafkaITCase.java b/src/it/producer-consumer-api/src/test/java/KafkaITCase.java
@@ -23,6 +23,7 @@
  */
 
 import org.cactoos.list.ListOf;
+import org.junit.AfterClass;
 import org.junit.jupiter.api.BeforeAll;
 import org.slf4j.LoggerFactory;
 import org.testcontainers.containers.KafkaContainer;
@@ -37,6 +38,9 @@
  */
 public abstract class KafkaITCase {
 
+  /**
+   * Kafka Docker Container.
+   */
   protected static final KafkaContainer KAFKA = new KafkaContainer(
     DockerImageName.parse("confluentinc/cp-kafka:7.3.0")
   )
@@ -50,6 +54,9 @@ public abstract class KafkaITCase {
       )
     )
     .withEmbeddedZookeeper();
+  /**
+   * Bootstrap servers.
+   */
   protected static String servers;
 
   @BeforeAll
@@ -70,4 +77,9 @@ static void setup() {
       )
     );
   }
+
+  @AfterClass
+  void tearDown() {
+    KafkaITCase.KAFKA.stop();
+  }
 }