A stream restarts with its original checkpoint after a worker failure. What is the checkpoint's primary role?

Published
  1. Replace source retention and make replay data unnecessary
  2. Prevent all schema incompatibilities in changed code
  3. Restore processing progress and supported streaming state
  4. Guarantee every arbitrary external API call happened once

Comments — 0