Merge pull request #430 from agebhar1/feature/[email protected]

build(deps-dev): bump testcontainers from 1.20.2 to 1.20.3

pom.xml

@@ -38,7 +38,7 @@
         <org.mockito.version>5.14.2</org.mockito.version>
         <org.slf4j.version>2.0.16</org.slf4j.version>
         <org.skyscreamer.version>1.5.3</org.skyscreamer.version>
-        <org.testcontainers.version>1.20.2</org.testcontainers.version>
+        <org.testcontainers.version>1.20.3</org.testcontainers.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
 

src/test/java/software/amazon/event/kafkaconnector/AbstractEventBridgeSinkConnectorIT.java

@@ -31,14 +31,14 @@
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.StringSerializer;
 import org.apache.kafka.connect.json.JsonSerializer;
+import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.TestInstance;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.testcontainers.containers.DockerComposeContainer;
 import org.testcontainers.containers.output.Slf4jLogConsumer;
 import org.testcontainers.containers.wait.strategy.Wait;
-import org.testcontainers.junit.jupiter.Container;
 import org.testcontainers.junit.jupiter.Testcontainers;
 import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
 import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;
@@ -84,8 +84,7 @@ public abstract class AbstractEventBridgeSinkConnectorIT {
   protected static final Logger log =
       LoggerFactory.getLogger(AbstractEventBridgeSinkConnectorIT.class);
 
-  @Container
-  private static final DockerComposeContainer<?> environment =
+  private final DockerComposeContainer<?> environment =
       new DockerComposeContainer<>("e2e", getComposeFile())
           .withLogConsumer("connect", new Slf4jLogConsumer(log).withSeparateOutputStreams())
           .withEnv("AWS_ACCESS_KEY_ID", AWS_ACCESS_KEY_ID)
@@ -120,6 +119,16 @@ public abstract class AbstractEventBridgeSinkConnectorIT {
           new JsonSerializer());
 
   @BeforeAll
+  public void setup() {
+    environment.start();
+    createAwsResources();
+  }
+
+  @AfterAll
+  public void tearDown() {
+    environment.stop();
+  }
+
   public void createAwsResources() {
     log.info("creating aws localstack resources");
     var credentials =