void setReplicaToken(RemoteReplicaInfo replicaInfo) {
    String partitionKey = String.valueOf(replicaInfo.getReplicaId().getPartitionId().getId());
    String rowKey = replicaInfo.getReplicaId().getDataNodeId().getHostname();
    FindTokenFactory findTokenFactory = findTokenHelper.getFindTokenFactoryFromReplicaType(ReplicaType.DISK_BACKED);
    try {
      TableEntity row = cloudDestination.getTableEntity(azureTableNameReplicaTokens, partitionKey, rowKey);
      if (row == null) {
        logger.warn("Resetting token for replica {}/{} because no token found", partitionKey, rowKey);
        replicaInfo.setToken(findTokenFactory.getNewFindToken());
      } else {
        DataInputStream inputStream = new DataInputStream(
            new ByteArrayInputStream((byte[]) row.getProperty(VcrReplicationManager.BINARY_TOKEN)));
        replicaInfo.setToken(findTokenFactory.getFindToken(inputStream));
        logger.info("Loaded token for replica {}/{}, token = {}", partitionKey, rowKey, replicaInfo.getToken());
      }
    } catch (Throwable t) {
      azureMetrics.replicaTokenReadErrorCount.inc();
      logger.error("Resetting token for replica {}/{} due to {}", partitionKey, rowKey, t.toString());
      replicaInfo.setToken(findTokenFactory.getNewFindToken());
    } // try-catch
  }
Fetch replica-token from Azure and set it in the thread
@param replicaInfo
ambry-cloud/src/main/java/com/github/ambry/cloud/VcrReplicaThread.java