public JobCoordinatorMetadata readJobCoordinatorMetadata() {
    JobCoordinatorMetadata metadata = null;
    for (Map.Entry<String, byte[]> entry : metadataStore.all().entrySet()) {
      if (clusterType.name().equals(entry.getKey())) {
        try {
          String metadataString = valueSerde.fromBytes(entry.getValue());
          metadata = metadataMapper.readValue(metadataString, JobCoordinatorMetadata.class);
          break;
        } catch (Exception e) {
          metrics.incrementMetadataReadFailedCount();
          LOG.error("Failed to read job coordinator metadata due to ", e);
        }
      }
    }

    LOG.info("Fetched the job coordinator metadata for cluster {} as {}.", clusterType, metadata);
    return metadata;
  }
Reads the {@link JobCoordinatorMetadata} from the metadata store. It fetches the metadata
associated with cluster type specified at the creation of the manager.

@return job coordinator metadata
samza-core/src/main/java/org/apache/samza/job/metadata/JobCoordinatorMetadataManager.java