updated EventConvertingCallbackStream so that it returns events that we failed to process so that higher retries can applied.