private static Map<TaskId, Long> getTaskOffsetSums(final Collection<TaskId> activeTasks) {
        final Map<TaskId, Long> taskOffsetSums = activeTasks.stream().collect(Collectors.toMap(t -> t, t -> Task.LATEST_OFFSET));
        taskOffsetSums.putAll(EMPTY_TASKS.stream().collect(Collectors.toMap(t -> t, t -> 0L)));
        return taskOffsetSums;
    }
Helper for building the input to createMockAdminClient in cases where we don't care about the actual offsets
@param changelogTopics The names of all changelog topics in the topology
@param topicsNumPartitions The number of partitions for the corresponding changelog topic, such that the number
           of partitions of the ith topic in changelogTopics is given by the ith element of topicsNumPartitions
streams/src/test/java/org/apache/kafka/streams/processor/internals/RackAwarenessStreamsPartitionAssignorTest.java