public synchronized void updatePreferredReadReplica(TopicPartition tp, int preferredReadReplicaId, LongSupplier timeMs) {
        assignedState(tp).updatePreferredReadReplica(preferredReadReplicaId, timeMs);
    }
Set the preferred read replica with a lease timeout. After this time, the replica will no longer be valid and
{@link #preferredReadReplica(TopicPartition, long)} will return an empty result.

@param tp The topic partition
@param preferredReadReplicaId The preferred read replica
@param timeMs The time at which this preferred replica is no longer valid
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java