improved failure handling in changes stream