THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
class RackAwareReplicaSelector implements ReplicaSelector { Node select(String rackId, PartitionInfo partitionInfo) { // if rackId is not null, iterate through the online replicas // if one or more exists with matching rackId, choose a replica randomly from among them // otherwise return the current leader } } |
...