What is the purpose of checkpointing in a streaming application?
- A Persisting state and progress so processing can resume correctly after a failure
- B Compressing the stream
- C Validating the schema
- D Reducing latency
Answer
Persisting state and progress so processing can resume correctly after a failure
Without reliable checkpoints, a restart either reprocesses everything or silently loses events between the last commit and the failure.





