diff --git a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/SnapshotReader.java b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/SnapshotReader.java
index 2061e966c..f0a8b658f 100644
--- a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/SnapshotReader.java
+++ b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/SnapshotReader.java
@@ -605,7 +605,7 @@ protected void execute() {
                                                 Column actualColumn = table.columns().get(i);
                                                 row[i] = readField(rs, j, actualColumn, table);
                                             }
-                                            recorder.recordRow(recordMaker, row, ts); // has no row number!
+                                            recorder.recordRow(recordMaker, row, clock.currentTimeInMillis()); // has no row number!
                                             rowNum.incrementAndGet();
                                             if (rowNum.get() % 100 == 0 && !isRunning()) {
                                                 // We've stopped running ...