A. Sophie Blee-Goldman created KAFKA-12742:
----------------------------------------------
Summary: 5. Checkpoint all uncorrupted state stores within the
subtopology
Key: KAFKA-12742
URL: https://issues.apache.org/jira/browse/KAFKA-12742
Project: Kafka
Issue Type: Sub-task
Components: streams
Reporter: A. Sophie Blee-Goldman
Once we have [KAFKA-12740|https://issues.apache.org/jira/browse/KAFKA-12740],
we can close the loop on EOS by checkpointing not only those state stores which
are attached to processors that the record has successfully passed, but also
any remaining state stores further downstream in the subtopology that aren't
connected to the processor where the error occurred.
At this point, outside of a hard crash (eg process is killed) or dropping out
of the group, we’ll only ever need to restore state stores from scratch if the
exception came from the specific processor node they’re attached to. Which is
pretty darn cool
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
