Keep the slot moving (#594)

PeerDB-io · Oct 30, 2023 · 3f10c9c · 3f10c9c
1 parent 23aa623
commit 3f10c9c
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
@@ -361,6 +361,12 @@ func (p *PostgresCDCSource) consumeStream(
 				clientXLogPos = xld.WALStart
 				records.UpdateLatestCheckpoint(int64(clientXLogPos))
 			}
+
+			if len(localRecords) == 0 {
+				// given that we have no records it is safe to update the flush wal position
+				// to the clientXLogPos. clientXLogPos can be moved forward due to PKM messages.
+				consumedXLogPos = clientXLogPos
+			}
 		}
 	}
 }