On 03/01/2016 03:10 PM, Jagadish Venkatraman wrote:
You don't have to implement any state checkpoint. Samza automatically checkpoints state for you. When you recover from a failure/restart you will resume processing from the previous checkpoint.
So, it's merely a configuration issue?
What's your usecase?
Pretty standard: have a consumer processing messages, which dies. When it comes back up, it needs to process messages not just from when it died, but perhaps 24 hours prior to that time.
-- Jeff Ramin Software Engineer Singlewire Software 2601 W Beltline Hwy #510 Madison, WI 53713 Phone Direct - 608.661.1172 www.singlewire.com
