diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go index 65924c13f..c8a9fe769 100644 --- 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:])