default boolean maybePunctuateSystemTime() {
        return false;
    }
Fetches up-to-date lag information from the consumer.
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java