With Traditional snapshot process. `source.ts_ms` value is increasing as the records are fetched from database. this is causing out of order events and causing older version of a data to be represented with new TS .
see zulip thread
`source.ts_ms` should be static and set before the data export starts.
currently its assigned by the time record is emitted.
- use 0 for snapshot `r` events
- take TS at the start of table snapshot and use it for all records that of table.