public void signalResume() {
        if (stateUpdater != null) {
            stateUpdater.signalResume();
        }
        if (schedulingTaskManager != null) {
            schedulingTaskManager.signalTaskExecutors();
        }
    }
Closes active tasks as zombies, as these partitions have been lost and are no longer owned.
NOTE this method assumes that when it is called, EVERY task/partition has been lost and must
be closed as a zombie.

@throws TaskMigratedException if the task producer got fenced (EOS only)
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java