Fixing record stream throttling for processing