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
