diff --git a/replication/row_event.go b/replication/row_event.go
index 1972cb217..62e34318d 100644
--- a/replication/row_event.go
+++ b/replication/row_event.go
@@ -1085,6 +1085,7 @@ func (e *RowsEvent) DecodeData(pos int, data []byte) (err2 error) {
 			//nolint:nakedret
 			return
 		}
+		pos = 0
 	}
 
 	// Rows_log_event::print_verbose()