public void signalTaskExecutors() {
        if (schedulingTaskManager != null) {
            // Wake up sleeping task executors after every poll, in case there is processing or punctuation to-do.
            schedulingTaskManager.signalTaskExecutors();
        }
    }
Wake-up any sleeping processing threads.
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java