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

PeerDB-io · Nov 21, 2023 · 2eb549d · 2eb549d
2 parents cd390e1 + 41fd15d
commit 2eb549d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
@@ -324,9 +324,9 @@ func (p *PostgresCDCSource) consumeStream(
 				clientXLogPos = pkm.ServerWALEnd
 			}
 
-			if pkm.ReplyRequested {
-				pkmRequiresResponse = true
-			}
+			// always reply to keepalive messages
+			// instead of `pkm.ReplyRequested`
+			pkmRequiresResponse = true
 
 		case pglogrepl.XLogDataByteID:
 			xld, err := pglogrepl.ParseXLogData(msg.Data[1:])