diff --git a/core/src/main/scala/akka/persistence/dynamodb/internal/BySliceQuery.scala b/core/src/main/scala/akka/persistence/dynamodb/internal/BySliceQuery.scala
index 8ff9217..b8f9f54 100644
--- a/core/src/main/scala/akka/persistence/dynamodb/internal/BySliceQuery.scala
+++ b/core/src/main/scala/akka/persistence/dynamodb/internal/BySliceQuery.scala
@@ -71,11 +71,8 @@ import org.slf4j.Logger
       else latest
 
     def nextQueryFromTimestamp(backtrackingWindow: JDuration): Instant =
-      if (backtracking) {
-        if (latest.timestamp.minus(backtrackingWindow).isAfter(latestBacktracking.timestamp))
-          latest.timestamp.minus(backtrackingWindow)
-        else latestBacktracking.timestamp
-      } else latest.timestamp
+      if (backtracking) latestBacktracking.timestamp
+      else latest.timestamp
 
     def nextQueryToTimestamp: Option[Instant] = {
       if (backtracking) Some(latest.timestamp)