We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fafb027 commit b97f4ceCopy full SHA for b97f4ce
lib/sequin/databases_runtime/slot_processor.ex
@@ -384,8 +384,9 @@ defmodule Sequin.DatabasesRuntime.SlotProcessor do
384
reply == 1 ->
385
# If we don't have a last_commit_lsn, we're still processing the first xaction
386
# we received on boot. This can happen if we're processing a very large xaction.
387
- # It is therefore safe to send an ack with the current_xaction_lsn
388
- ack_message(state.current_xaction_lsn)
+ # It is therefore safe to send an ack with the last LSN we processed.
+ {:ok, low_watermark} = Replication.low_watermark_wal_cursor(state.id)
389
+ ack_message(low_watermark.commit_lsn)
390
391
true ->
392
[]
0 commit comments