Fixing issue where move to latest offset wasn't preserved for future runs if there was no new data for a partition