protected static Map<TaskId, Set<TopicPartition>> getActiveTasks(final List<TopicPartition> partitions, final AssignmentInfo info) {
        final Map<TaskId, Set<TopicPartition>> activeTasks = new HashMap<>();
        for (int i = 0; i < partitions.size(); i++) {
            final TopicPartition partition = partitions.get(i);
            final TaskId id = info.activeTasks().get(i);
            activeTasks.computeIfAbsent(id, k1 -> new HashSet<>()).add(partition);
        }
        return activeTasks;
    }
Verify that this client's host info was included in the map returned in the assignment, and trigger a
rebalance if not. This may be necessary when using static membership, as a rejoining client will be handed
back its original assignment to avoid an unnecessary rebalance. If the client's endpoint has changed, we need
to force a rebalance for the other members in the group to get the updated host info for this client.

@param groupHostInfo the HostInfo of all clients in the group
@return false if the current host info does not match that in the group assignment
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java