static ReplicateBlobRequest readFrom(DataInputStream stream, ClusterMap map) throws IOException {
      int correlationId = stream.readInt();
      String clientId = Utils.readIntString(stream);
      BlobId id = new BlobId(stream, map);
      String sourceHostName = Utils.readIntString(stream);
      int sourceHostPort = stream.readInt();
      return new ReplicateBlobRequest(correlationId, clientId, id, sourceHostName, sourceHostPort);
    }
Class to read protocol version 1 ReplicateBlobRequest from the stream.
ambry-protocol/src/main/java/com/github/ambry/protocol/ReplicateBlobRequest.java