diff --git a/engine/src/main/java/io/camunda/zeebe/process/test/engine/InMemoryLogStorage.java b/engine/src/main/java/io/camunda/zeebe/process/test/engine/InMemoryLogStorage.java index 4a4fc773f..7bda0d4da 100644 --- a/engine/src/main/java/io/camunda/zeebe/process/test/engine/InMemoryLogStorage.java +++ b/engine/src/main/java/io/camunda/zeebe/process/test/engine/InMemoryLogStorage.java @@ -54,9 +54,9 @@ public void append( logEntries.add(blockBuffer); final int index = logEntries.size(); positionIndexMapping.put(lowestPosition, index); - listener.onWrite(index); + listener.onWrite(index, highestPosition); - listener.onCommit(index); + listener.onCommit(index, highestPosition); commitListeners.forEach(CommitListener::onCommit); }