kafka
kafka copied to clipboard
How to handle the errors in consumer?
I have a simple consumer and I am trying to read from offsets 3 to 5 which do not exist. I want to catch the OffsetOutofRange error and need to do some operations.
Any idea of how to catch this error?
There is no good way to do this. no-kafka will automatically update subscription offset as per recoveryOffset
option.
thanks