deps: bump version.zeebe from 8.2.13 to 8.3.4

.github/workflows/test.yml

@@ -97,7 +97,7 @@ jobs:
         uses: actions/upload-artifact@v4
         if: always()
         with:
-          name: cloud-core-test-results
+          name: cloud-engine-test-results
           path: "**/target/surefire-reports/**"
           retention-days: 3
   exporter:

core/src/test/java/io/zeebe/containers/examples/archive/RestartWithExtractedDataExampleTest.java

@@ -82,7 +82,10 @@ void shouldGenerateData() throws IOException {
     final Path destination = tempDir.resolve(DATA_DIR);
 
     // when
-    try (final ZeebeContainer container = new ZeebeContainer().withZeebeData(volume)) {
+    try (final ZeebeContainer container =
+        new ZeebeContainer()
+            .withCreateContainerCmdModifier(cmd -> cmd.withUser("1001:0"))
+            .withZeebeData(volume)) {
       container.start();
       deployProcess(container);
     }
@@ -110,6 +113,7 @@ void shouldRestartWithGeneratedData() {
     // when
     try (final ZeebeContainer container =
         new ZeebeContainer()
+            .withCreateContainerCmdModifier(cmd -> cmd.withUser("1001:0"))
             .withCopyFileToContainer(
                 MountableFile.forHostPath(dataPath),
                 ZeebeDefaults.getInstance().getDefaultDataPath())) {
@@ -130,7 +134,7 @@ private void deployProcess(final ZeebeContainer container) {
             .gatewayAddress(container.getExternalGatewayAddress())
             .build()) {
       client
-          .newDeployCommand()
+          .newDeployResourceCommand()
           .addProcessModel(
               Bpmn.createExecutableProcess(PROCESS_ID).startEvent().endEvent().done(),
               "process.bpmn")

engine/pom.xml

@@ -78,6 +78,11 @@
       <artifactId>testcontainers</artifactId>
     </dependency>
 
+    <dependency>
+      <groupId>com.fasterxml.jackson.core</groupId>
+      <artifactId>jackson-databind</artifactId>
+    </dependency>
+
     <!-- Test dependencies -->
 
     <dependency>

engine/src/main/java/io/zeebe/containers/engine/ZeebeClusterEngine.java

@@ -15,7 +15,10 @@
  */
 package io.zeebe.containers.engine;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import io.camunda.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClientBuilder;
+import io.camunda.zeebe.client.impl.ZeebeObjectMapper;
 import io.camunda.zeebe.process.test.api.RecordStreamSource;
 import io.zeebe.containers.ZeebeNode;
 import io.zeebe.containers.clock.ZeebeClock;
@@ -25,6 +28,7 @@
 import java.util.Collection;
 import java.util.List;
 import java.util.concurrent.TimeoutException;
+import java.util.function.UnaryOperator;
 import org.agrona.CloseHelper;
 import org.apiguardian.api.API;
 import org.apiguardian.api.API.Status;
@@ -65,10 +69,12 @@ public RecordStreamSource getRecordStreamSource() {
 
   @Override
   public ZeebeClient createClient() {
-    final ZeebeClient client = cluster.newClientBuilder().build();
-    clients.add(client);
+    return createClient(UnaryOperator.identity());
+  }
 
-    return client;
+  @Override
+  public ZeebeClient createClient(final ObjectMapper customObjectMapper) {
+    return createClient(b -> b.withJsonMapper(new ZeebeObjectMapper(customObjectMapper)));
   }
 
   @Override
@@ -106,4 +112,14 @@ public void stop() {
 
     CloseHelper.closeAll(cluster, recordStream);
   }
+
+  private ZeebeClient createClient(final UnaryOperator<ZeebeClientBuilder> configurator) {
+    final ZeebeClientBuilder builder =
+        configurator.apply(
+            ZeebeClient.newClientBuilder().usePlaintext().gatewayAddress(getGatewayAddress()));
+    final ZeebeClient client = builder.build();
+    clients.add(client);
+
+    return client;
+  }
 }

engine/src/main/java/io/zeebe/containers/engine/ZeebeContainerEngine.java

@@ -15,7 +15,10 @@
  */
 package io.zeebe.containers.engine;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import io.camunda.zeebe.client.ZeebeClient;
+import io.camunda.zeebe.client.ZeebeClientBuilder;
+import io.camunda.zeebe.client.impl.ZeebeObjectMapper;
 import io.camunda.zeebe.process.test.api.RecordStreamSource;
 import io.zeebe.containers.ZeebeBrokerNode;
 import io.zeebe.containers.ZeebeContainer;
@@ -26,6 +29,7 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.TimeoutException;
+import java.util.function.UnaryOperator;
 import org.agrona.CloseHelper;
 import org.apiguardian.api.API;
 import org.apiguardian.api.API.Status;
@@ -63,11 +67,12 @@ public RecordStreamSource getRecordStreamSource() {
 
   @Override
   public ZeebeClient createClient() {
-    final ZeebeClient client =
-        ZeebeClient.newClientBuilder().usePlaintext().gatewayAddress(getGatewayAddress()).build();
-    clients.add(client);
+    return createClient(UnaryOperator.identity());
+  }
 
-    return client;
+  @Override
+  public ZeebeClient createClient(final ObjectMapper objectMapper) {
+    return createClient(b -> b.withJsonMapper(new ZeebeObjectMapper(objectMapper)));
   }
 
   @Override
@@ -105,4 +110,14 @@ public void stop() {
 
     CloseHelper.closeAll(container, recordStream);
   }
+
+  private ZeebeClient createClient(final UnaryOperator<ZeebeClientBuilder> configurator) {
+    final ZeebeClientBuilder builder =
+        configurator.apply(
+            ZeebeClient.newClientBuilder().usePlaintext().gatewayAddress(getGatewayAddress()));
+    final ZeebeClient client = builder.build();
+    clients.add(client);
+
+    return client;
+  }
 }

pom.xml

@@ -77,7 +77,7 @@
     <version.slf4j>2.0.1</version.slf4j>
     <version.testcontainers>1.19.0</version.testcontainers>
     <version.wiremock>2.35.1</version.wiremock>
-    <version.zeebe>8.2.13</version.zeebe>
+    <version.zeebe>8.3.4</version.zeebe>
 
     <!-- plugin version -->
     <plugin.version.checkstyle>3.3.1</plugin.version.checkstyle>