CIRCSTORE-656 Upgrade dependencies for Kafka 4.2 compatibility

Author: roman-barannyk

pom.xml

@@ -28,7 +28,7 @@
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
     <ramlfiles_path>${basedir}/ramls</ramlfiles_path>
-    <vertx-version>5.0.5</vertx-version>
+    <vertx-version>5.0.12</vertx-version>
     <raml-module-builder-version>36.0.0</raml-module-builder-version>
     <spring.version>6.2.3</spring.version>
     <junit5.version>5.10.2</junit5.version>
@@ -84,7 +84,12 @@
     <dependency>
       <groupId>org.folio</groupId>
       <artifactId>folio-kafka-wrapper</artifactId>
-      <version>4.0.0</version>
+      <version>4.1.0-SNAPSHOT</version>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.kafka</groupId>
+      <artifactId>kafka-clients</artifactId>
+      <version>4.2.0</version>
     </dependency>
     <dependency>
       <groupId>junit</groupId>

src/test/java/org/folio/rest/api/StorageTestSuite.java

@@ -40,6 +40,7 @@
 import org.junit.platform.suite.api.SelectClasses;
 import org.junit.platform.suite.api.Suite;
 import org.testcontainers.kafka.KafkaContainer;
+import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.utility.DockerImageName;
 
 import com.github.tomakehurst.wiremock.WireMockServer;
@@ -98,9 +99,15 @@ public class StorageTestSuite {
   private static MockServer mockServer;
   private static final WireMockServer wireMockServer = new WireMockServer(PROXY_PORT);
 
-  private static final KafkaContainer kafkaContainer = new KafkaContainer(DockerImageName.parse("apache/kafka-native:3.8.0"))
+  private static final KafkaContainer kafkaContainer = new KafkaContainer(DockerImageName.parse("apache/kafka-native:4.2.0"))
       .withStartupAttempts(3);
 
+  @SuppressWarnings("resource")
+  private static final GenericContainer<?> sidecarContainer = new GenericContainer<>(
+      DockerImageName.parse("folioci/folio-module-sidecar:latest"))
+      .withExposedPorts(8081)
+      .withNetworkAliases("folio-module-sidecar");
+
   /**
    * Return a URL for the path and the parameters.
    *
@@ -152,6 +159,7 @@ public static void before() throws InterruptedException,
     PostgresClient.setPostgresTester(new PostgresTesterContainer());
 
     kafkaContainer.start();
+    sidecarContainer.start();
     var host = kafkaContainer.getHost();
     var port = String.valueOf(kafkaContainer.getFirstMappedPort());
     log.info("Starting Kafka host={} port={}", host, port);
@@ -202,6 +210,12 @@ public static void after()
       log.warn("after:: kafkaContainer.stop() failed (ignored): {}", e.getMessage());
     }
 
+    try {
+      sidecarContainer.stop();
+    } catch (Throwable e) {
+      log.warn("after:: sidecarContainer.stop() failed (ignored): {}", e.getMessage());
+    }
+
     try {
       mockServer.close();
     } catch (Throwable e) {