private void registerRebalanceListener(Optional<ConsumerRebalanceListener> listener) {
        this.rebalanceListener = Objects.requireNonNull(listener, "RebalanceListener cannot be null");
    }
Change the assignment to the specified partitions returned from the coordinator, note this is
different from {@link #assignFromUser(Set)} which directly set the assignment from user inputs.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java