public Set<TaskId> corruptedTasks() {
        return corruptedTasks;
    }
Indicates a specific task is corrupted and need to be re-initialized. It can be thrown when:

<ol>
  <li>Under EOS, if the checkpoint file does not contain offsets for corresponding store's changelogs, meaning previously it was not close cleanly.</li>
  <li>Out-of-range exception thrown during restoration, meaning that the changelog has been modified and we re-bootstrap the store.</li>
</ol>
streams/src/main/java/org/apache/kafka/streams/errors/TaskCorruptedException.java