public void updateReplicationFetchBytes(RemoteReplicaInfo remoteReplica, long totalBytesFixed) {
    String replicaFetchBytes = generateRemoteReplicaMetricPrefix(remoteReplica) + REPLICATION_FETCH_BYTES_RATE_SUFFIX;
    if (replicaToReplicationFetchBytesRateMap.containsKey(replicaFetchBytes)) {
      replicaToReplicationFetchBytesRateMap.get(replicaFetchBytes).mark(totalBytesFixed);
    }
  }
Add metrics for given remote replica.
@param remoteReplicaInfo the {@link RemoteReplicaInfo} that contains all infos associated with remote replica
@param trackPerDatacenterLag whether to track remote replicas' lag from local by each datacenter. Specifically, it
                             tracks min/max/avg remote replica lag from each datacenter.
@param trackPerReplicaReplicationBytes whether to track replicated bytes per second from each remote replica,
                                       replica thread is replicating from.
ambry-replication/src/main/java/com/github/ambry/replication/ReplicationMetrics.java