public boolean canPunctuateSystemTime() {
        final long systemTime = time.milliseconds();
        return systemTimePunctuationQueue.canPunctuate(systemTime);
    }
Possibly trigger registered system-time punctuation functions if
current system timestamp has reached the defined stamp
Note, this is called irrespective of the presence of new records

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