To retry based on number of attempts, use:
StreamRetry.maxAttempts(5) Copy
StreamRetry.maxAttempts(5)
To retry based on the age of a record, use:
StreamRetry.maxAge(Duration.minutes(5)) Copy
StreamRetry.maxAge(Duration.minutes(5))
Readonly
Static
To retry based on number of attempts, use:
To retry based on the age of a record, use: