Keep the slot moving

PeerDB-io · Oct 30, 2023 · fdbb8de · fdbb8de
1 parent 7e1723e
commit fdbb8de
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.LastCheckPointID = 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
+			}
 		}
 	}
 }