public boolean canPunctuateStreamTime() {
        final long streamTime = partitionGroup.streamTime();
        return streamTimePunctuationQueue.canPunctuate(streamTime);
    }
Possibly trigger registered stream-time punctuation functions if
current partition group timestamp has reached the defined stamp
Note, this is only called in 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