public void updateLags() {
        for (final Task t: tasks.activeTasks()) {
            t.updateLags();
        }
    }
Fetches up-to-date lag information from the consumer.
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java