Added return to consumer method for fine-level control over handling failures