diff --git a/engine/src/main/java/io/camunda/zeebe/process/test/engine/EngineFactory.java b/engine/src/main/java/io/camunda/zeebe/process/test/engine/EngineFactory.java
index 9ca845a33..6c93f1d96 100644
--- a/engine/src/main/java/io/camunda/zeebe/process/test/engine/EngineFactory.java
+++ b/engine/src/main/java/io/camunda/zeebe/process/test/engine/EngineFactory.java
@@ -8,6 +8,7 @@
 package io.camunda.zeebe.process.test.engine;
 
 import io.camunda.zeebe.db.ZeebeDb;
+import io.camunda.zeebe.engine.Engine;
 import io.camunda.zeebe.engine.processing.EngineProcessors;
 import io.camunda.zeebe.engine.processing.deployment.distribute.DeploymentDistributionCommandSender;
 import io.camunda.zeebe.engine.processing.message.command.SubscriptionCommandSender;
@@ -147,18 +148,19 @@ private static StreamProcessor createStreamProcessor(
     return StreamProcessor.builder()
         .logStream(logStream)
         .zeebeDb(database)
-        .eventApplierFactory(EventAppliers::new)
         .commandResponseWriter(grpcResponseWriter)
-        .streamProcessorFactory(
-            context ->
-                EngineProcessors.createEngineProcessors(
-                    context,
-                    partitionCount,
-                    new SubscriptionCommandSender(context.getPartitionId(), commandSender),
-                    new DeploymentDistributionCommandSender(
-                        context.getPartitionId(), commandSender),
-                    jobType -> {},
-                    FeatureFlags.createDefault()))
+        .eventApplierFactory(EventAppliers::new)
+        .recordProcessor(
+            new Engine(
+                context ->
+                    EngineProcessors.createEngineProcessors(
+                        context,
+                        partitionCount,
+                        new SubscriptionCommandSender(context.getPartitionId(), commandSender),
+                        new DeploymentDistributionCommandSender(
+                            context.getPartitionId(), commandSender),
+                        jobType -> {},
+                        FeatureFlags.createDefault())))
         .actorSchedulingService(scheduler)
         .build();
   }
diff --git a/pom.xml b/pom.xml
index f51659971..cabc8e94f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -73,7 +73,7 @@
     <dependency.snakeyaml.version>1.30</dependency.snakeyaml.version>
     <dependency.spring.version>5.3.22</dependency.spring.version>
     <dependency.testcontainers.version>1.17.3</dependency.testcontainers.version>
-    <dependency.zeebe.version>8.1.0-alpha4</dependency.zeebe.version>
+    <dependency.zeebe.version>8.1.0-SNAPSHOT</dependency.zeebe.version>
 
     <license.header>com/mycila/maven/plugin/license/templates/APACHE-2.txt</license.header>