Merge pull request #352 from camunda-community-hub/np-allow-setting-d…

…ebug-port

feat(engine): allow setting the exporter receiver port

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

@@ -164,6 +164,15 @@ interface Builder {
      */
     Builder withAutoAcknowledge(final boolean acknowledge);
 
+    /**
+     * Pre-assigns the port to use for the debug receive, i.e. the socket used to receive exported
+     * records from the container(s). By default, this is 0, i.e. a random port.
+     *
+     * @param port the port to assign to the receiver
+     * @return itself for chaining
+     */
+    Builder withDebugReceiverPort(final int port);
+
     /**
      * Builds a {@link ContainerEngine} based on the configuration. If nothing else was called, will
      * build an engine using a default {@link io.zeebe.containers.ZeebeContainer}, an idle period of

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

@@ -42,6 +42,7 @@ final class ContainerEngineBuilder implements Builder {
   private Duration idlePeriod;
   private Duration gracePeriod;
   private boolean autoAcknowledge;
+  private int debugReceiverPort;
 
   @Override
   public <T extends GenericContainer<T> & ZeebeGatewayNode<T> & ZeebeBrokerNode<T>>
@@ -99,15 +100,23 @@ public Builder withAutoAcknowledge(final boolean autoAcknowledge) {
     return this;
   }
 
-  @SuppressWarnings("unchecked")
+  @Override
+  public Builder withDebugReceiverPort(final int debugReceiverPort) {
+    this.debugReceiverPort = debugReceiverPort;
+    return this;
+  }
+
+  @SuppressWarnings({"unchecked", "rawtypes"})
   @Override
   public ContainerEngine build() {
     final Duration listGracePeriod = Optional.ofNullable(gracePeriod).orElse(DEFAULT_GRACE_PERIOD);
     final Duration receiveIdlePeriod = Optional.ofNullable(idlePeriod).orElse(DEFAULT_IDLE_PERIOD);
     final InfiniteList<Record<?>> records = new InfiniteList<>(listGracePeriod);
     final DebugReceiverStream recordStream =
         new DebugReceiverStream(
-            records, new DebugReceiver(records::add, autoAcknowledge), receiveIdlePeriod);
+            records,
+            new DebugReceiver(records::add, debugReceiverPort, autoAcknowledge),
+            receiveIdlePeriod);
 
     try {
       if (container != null) {