-
Bug
-
Resolution: Done
-
Major
-
0.9.5.Final
-
None
The ts_ms described as "ts_ms is optional and if present contains the time (using the system clock in the JVM running the Kafka Connect task) at which the connector processed the event." from official documentation with link https://debezium.io/documentation/reference/0.9/connectors/mysql.html
As it said ts_ms as the processed time fo the event, so I think the during the snapshot every record is an event, so the ts_ms values are not the same during the snapshot, but in fact the ts_ms is the same value, Also I have read the source code io.debezium.connector.mysql.SnapshotReader#execute the variable ts is assign the value from the beginning and use to:
recorder.recordRow(recordMaker, row, ts); // has no row number!
So the ts will not change during the snapshot processing, also agains with the official documentation.