Skip to content

Commit 26b21eb

Browse files
authored
chore: remove obsolete outside backtracking debug log (#132)
1 parent 07810d2 commit 26b21eb

File tree

1 file changed

+0
-10
lines changed

1 file changed

+0
-10
lines changed

core/src/main/scala/akka/persistence/dynamodb/internal/BySliceQuery.scala

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -222,16 +222,6 @@ import org.slf4j.Logger
222222
if (offset.timestamp.isBefore(state.latest.timestamp))
223223
throw new IllegalArgumentException(s"Unexpected offset [$offset] before latest [${state.latest}].")
224224

225-
if (log.isDebugEnabled()) {
226-
if (state.latestBacktracking.seen.nonEmpty &&
227-
offset.timestamp.isAfter(state.latestBacktracking.timestamp.plus(firstBacktrackingQueryWindow)))
228-
log.debug(
229-
"{} next offset is outside the backtracking window, latestBacktracking: [{}], offset: [{}]",
230-
logPrefix,
231-
state.latestBacktracking,
232-
offset)
233-
}
234-
235225
state.copy(latest = offset, itemCount = state.itemCount + 1)
236226
}
237227
}

0 commit comments

Comments
 (0)