Fix producer exception when no rows in stream