private void reassignPartition(TopicPartition partition, String newConsumer) {
            String consumer = currentPartitionConsumer.get(partition);
            // find the correct partition movement considering the stickiness requirement
            TopicPartition partitionToBeMoved = partitionMovements.getTheActualPartitionToBeMoved(partition, consumer, newConsumer);
            processPartitionMovement(partitionToBeMoved, newConsumer);
        }
Balance the current assignment using the data structures created in the assignPartitions(...) method above.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java