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.