consumer now uses resumption token - still gets all records every time though