Hi Team Just a reminder. Can you please help me with this?
Regards and Thanks Deepak Raghav On Tue, Sep 1, 2020 at 1:44 PM Deepak Raghav <deepakragha...@gmail.com> wrote: > Hi Team > > I have created a CustomExceptionHandler class by > implementing DeserializationExceptionHandler interface to handle the > exception during deserialization time. > > But the problem with this approach is that if there is some exception > raised for some record and after that stream is stopped and > restarted again, it reads those bad messages again. > > I am storing those bad messages in some file in the filesystem and with > this approach, duplicate messages are getting appended in the file when the > stream is started since those bad message's offset are not getting > increased. > > Please let me know if I missed anything. > > Regards and Thanks > Deepak Raghav > >
