public void incrementInvalidMessageError(PartitionId partitionId) {
    replicationInvalidMessageStreamErrorCount.inc();
    if (partitionIdToInvalidMessageStreamErrorCounter.containsKey(partitionId)) {
      partitionIdToInvalidMessageStreamErrorCounter.get(partitionId).inc();
    }
  }
Tracks the number of partitions for which replication is disabled.
@param replicaThreadPools A map of datacenter names to {@link ReplicaThread}s handling replication from that
                          datacenter
ambry-replication/src/main/java/com/github/ambry/replication/ReplicationMetrics.java