Retries handling - how to stop retrying a message after a number of failures

[kartius]

If parallel consumer got exception during the consuming event it try to process it again infinity amount. Could you suggest please, how can I handle retries and set a max limit?

[astubbs]

Sorry, I didn't see your report sooner. Thanks for contributing!

Ah - yes, simply catch exceptions from your function, and do not throw any exception back up. I.e. "swallow" the exception. This will make PC think the processing has succeeded, and will continue. You can record the number of failed attempts somewhere in your code, or you can use the new PollContext object in the master branch which provides you with the failure count.

Also keep an eye on:

• Provide option for max retires, and a call back when reached (potential DLQ) #196
• Enhanced retry epic #65
• Let user function throw retry exception, instead of raw errors which pollute log #242

See:

• refactor: Poll Context object for API #223