I’m trying to use the CommonDelegatingErrorHandler
to delegate to a couple of different DefaultErrorHandler
‘s depending on the exception thrown by the listener. My DefaultErrorHandler
‘s have seekAfterError
set to false
as that’s the behaviour I want (probably, my understanding of what it does isn’t concrete)
My listener was initially consuming batches, which worked fine. I’ve just tried to convert it to an individual record consumer and found that exceptions aren’t handled anymore because CommonDelegatingErrorHandler
doesn’t implement handleOne
Does anyone understand why this is the case? Looking at the CommonDelegatingErrorHandler
code I can’t see a reason for it to not implement handleOne
, and it implements all of the other handleX
methods from CommonErrorHandler
In my case, I can set seekAfterError
to true
in my DefaultErrorHandler
‘s, which means the handleRemaining
method is used, but ideally I wouldn’t have to do that and could use either behaviour of the DefaultErrorHandler
with the CommonDelegatingErrorHandler
Any insight would be much appreciated!