public synchronized void requestOffsetResetIfPartitionAssigned(TopicPartition partition) {
        final TopicPartitionState state = assignedStateOrNull(partition);
        if (state != null) {
            state.reset(defaultResetStrategy);
        }
    }
Unset the preferred read replica. This causes the fetcher to go back to the leader for fetches.

@param tp The topic partition
@return the removed preferred read replica if set, Empty otherwise.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java