Class TaskCorruptedException

All Implemented Interfaces:

public class TaskCorruptedException extends StreamsException
Indicates a specific task is corrupted and need to be re-initialized. It can be thrown when 1) Under EOS, if the checkpoint file does not contain offsets for corresponding store's changelogs, meaning previously it was not close cleanly; 2) Out-of-range exception thrown during restoration, meaning that the changelog has been modified and we re-bootstrap the store.
See Also:
  • Constructor Details

  • Method Details

    • corruptedTasks

      public Set<TaskId> corruptedTasks()