Long story short, no. Don't rely on checkpoints if you cant handle reprocessing some of your data.
On Thu, Mar 31, 2016 at 3:02 AM, Imre Nagi <[email protected]> wrote: > I'm dont know how to read the data from the checkpoint. But AFAIK and based > on my experience, I think the best thing that you can do is storing the > offset to a particular storage such as database everytime you consume the > message. Then read the offset from the database everytime you want to start > reading the message. > > nb: This approach is also explained by Cody in his blog post. > > Thanks > > On Thu, Mar 31, 2016 at 2:14 PM, vimal dinakaran <[email protected]> > wrote: >> >> Hi, >> In the blog >> https://github.com/koeninger/kafka-exactly-once/blob/master/blogpost.md >> >> It is mentioned that enabling checkpoint works as long as the app jar is >> unchanged. >> >> If I want to upgrade the jar with the latest code and consume from kafka >> where it was stopped , how to do that ? >> Is there a way to read the binary object of the checkpoint during init and >> use that to start from offset ? >> >> Thanks >> Vimal > > --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
