private void updateSubscriptionAwaitingCallback(SortedSet<TopicIdPartition> assignedPartitions,
                                                    SortedSet<TopicPartition> addedPartitions) {
        Collection<TopicPartition> assignedTopicPartitions = toTopicPartitionSet(assignedPartitions);
        subscriptions.assignFromSubscribedAwaitingCallback(assignedTopicPartitions, addedPartitions);
    }
Update a new assignment by setting the assigned partitions in the member subscription.
This will mark the newly added partitions as pending callback, to prevent fetching records
or updating positions for them while the callback runs.

@param assignedPartitions Full assignment, to update in the subscription state
@param addedPartitions    Newly added partitions
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java