[cdc] treat all pkms as reply_requested

PeerDB-io · Dec 12, 2024 · 281adf2 · 281adf2
1 parent 0a8fa90
commit 281adf2
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
@@ -495,15 +495,12 @@ func PullCdcRecords[Items model.Items](
 				return fmt.Errorf("ParsePrimaryKeepaliveMessage failed: %w", err)
 			}
 
-			logger.Debug("Primary Keepalive Message", slog.Any("data", pkm))
+			logger.Info("Primary Keepalive Message", slog.Any("data", pkm))
 
 			if pkm.ServerWALEnd > clientXLogPos {
 				clientXLogPos = pkm.ServerWALEnd
 			}
-
-			if pkm.ReplyRequested {
-				pkmRequiresResponse = true
-			}
+			pkmRequiresResponse = true
 
 		case pglogrepl.XLogDataByteID:
 			xld, err := pglogrepl.ParseXLogData(msg.Data[1:])