@Override
  public PartitionId getPartitionIdFromStream(InputStream stream) throws IOException {
    DataInputStream dataInputStream = new DataInputStream(stream);
    short version = dataInputStream.readShort();
    long id = dataInputStream.readLong();
    return partitions.get(id);
  }
Return if ssl ports are enabled in this cluster.
ambry-test-utils/src/main/java/com/github/ambry/clustermap/MockClusterMap.java