Re: Processor API StateStore and Recovery with State Machines question.

2018-07-26 Thread Adam Bellemare
Thanks Guozhang, I appreciate the explanation. That cleared up a lot for me and confirmed what I thought. Based on the above, in my scenario, the state machine could get into an incorrect state. (Just for whoever may be watching this thread). On Tue, Jul 24, 2018 at 6:20 PM, Guozhang Wang wrote:

Re: Processor API StateStore and Recovery with State Machines question.

2018-07-24 Thread Guozhang Wang
Hello Adam, I figured that rather than answering your questions one-by-one, I'd give you a more general explanation between consumer offset commits, changelog and state store. If you have a state store update processor, the state store maintenance workflow is this: 1) updating the state store: