We are struggling a bit with the recoverWithRetries and the events coming from a kafka subscriber.
The recoverWithRetries expects the original Source as input for retrying.
Except we seem not to get this from the subscriber, which return a CompletableStage.
We use the event subscriber for instance to hook up to an external system through http.
So it occurs that you have connectivity or other exceptions which restarts the client.
But what we actually want is to retry for 3 times and then persist the errornous event elsewhere.
Do you have an example somewhere on how to resolve this properly and gracefully handle this scenario?