Merge branch 'wait-for-at-least-one' into customer-mirage

PeerDB-io · Nov 17, 2023 · 69935ee · 69935ee
2 parents 6cb0be2 + a93499b
commit 69935ee
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
@@ -235,7 +235,7 @@ func (p *PostgresCDCSource) consumeStream(
 			pkmRequiresResponse = false
 		}
 
-		if len(localRecords) <= 1 {
+		if len(localRecords) == 0 {
 			log.Infof("pushing the standby deadline to %s", time.Now().Add(standbyMessageTimeout))
 			log.Infof("num records accumulated: %d", len(localRecords))
 			nextStandbyMessageDeadline = time.Now().Add(standbyMessageTimeout)