private static void controlReplicationForPartition(List<ConnectedChannel> channels, PartitionId partitionId,
      boolean enable) throws Exception {
    for (ConnectedChannel connectedChannel : channels) {
      AdminRequest adminRequest =
          new AdminRequest(AdminRequestOrResponseType.ReplicationControl, partitionId, 1, "clientid2");
      ReplicationControlAdminRequest controlRequest =
          new ReplicationControlAdminRequest(Collections.emptyList(), enable, adminRequest);
      DataInputStream stream = connectedChannel.sendAndReceive(controlRequest).getInputStream();
      AdminResponse adminResponse = AdminResponse.readFrom(stream);
      releaseNettyBufUnderneathStream(stream);
      Assert.assertEquals("Stop store admin request should succeed", ServerErrorCode.NoError, adminResponse.getError());
    }
  }
Test ReplicateBlob V2 code under different conditions.
1. test the data correctness of the on-demand replication on the target DataNode.
2. test the interaction between the regular replication and on-demand replication.
ambry-test-utils/src/main/java/com/github/ambry/server/ServerTestUtil.java