Hi @geofflane!
We’ve been discussing the possibility of adding a callback (or something similar) for that purpose. For now, one thing you could try would be wrapping the code that might fail inside handle_message/3 or handle_batch/4 in a try/catch block, do your stuff and then re-raise the exception (or set the message as failed using Message.failed/2).
Not optimal, I confess. But it might do the trick until we have a built-in solution.
Cheers.
-marlus






















