diff --git a/engine/src/main/java/io/camunda/zeebe/process/test/engine/db/InMemoryDbColumnFamily.java b/engine/src/main/java/io/camunda/zeebe/process/test/engine/db/InMemoryDbColumnFamily.java
index 4ddca74d0..a9a4aa341 100644
--- a/engine/src/main/java/io/camunda/zeebe/process/test/engine/db/InMemoryDbColumnFamily.java
+++ b/engine/src/main/java/io/camunda/zeebe/process/test/engine/db/InMemoryDbColumnFamily.java
@@ -140,6 +140,14 @@ public void whileEqualPrefix(
     whileEqualPrefix(context, keyPrefix, keyInstance, valueInstance, visitor);
   }
 
+  @Override
+  public void whileEqualPrefix(
+      final DbKey keyPrefix,
+      final KeyType startAtKey,
+      final KeyValuePairVisitor<KeyType, ValueType> visitor) {
+    whileEqualPrefix(context, startAtKey, keyPrefix, keyInstance, valueInstance, visitor);
+  }
+
   @Override
   public void deleteExisting(final KeyType key) {
     ensureInOpenTransaction(
diff --git a/filters/src/main/java/io/camunda/zeebe/process/test/filters/logger/RecordStreamLogger.java b/filters/src/main/java/io/camunda/zeebe/process/test/filters/logger/RecordStreamLogger.java
index 6a6de9ad2..65ed1ef61 100644
--- a/filters/src/main/java/io/camunda/zeebe/process/test/filters/logger/RecordStreamLogger.java
+++ b/filters/src/main/java/io/camunda/zeebe/process/test/filters/logger/RecordStreamLogger.java
@@ -112,6 +112,7 @@ public RecordStreamLogger(final RecordStreamSource recordStreamSource) {
     valueTypeLoggers.put(ValueType.RESOURCE_DELETION, this::logResourceDeletionRecordValue);
 
     valueTypeLoggers.put(ValueType.COMMAND_DISTRIBUTION, this::logCommandDistributionRecordValue);
+    valueTypeLoggers.put(ValueType.PROCESS_INSTANCE_BATCH, record -> "");
   }
 
   public void log() {