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