private void pauseResumePartitions(final Map<TaskId, Task> tasks,
                                       final Set<TopicPartition> restoringChangelogs) {
        if (state == ChangelogReaderState.ACTIVE_RESTORING) {
            updatePartitionsByType(tasks, restoringChangelogs, TaskType.ACTIVE);
        }
        if (state == ChangelogReaderState.STANDBY_UPDATING) {
            updatePartitionsByType(tasks, restoringChangelogs, TaskType.STANDBY);
        }
    }
Since it is shared for multiple tasks and hence multiple state managers, the registration would take its
corresponding state manager as well for restoring.
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java