public void createResources() {
    if (checkpointManager != null) {
      checkpointManager.createResources();
    }
    createChangelogStreams();
  }
Creates and loads the required metadata resources for checkpoints, changelog stream and other
resources related to the metadata system
samza-core/src/main/java/org/apache/samza/coordinator/MetadataResourceUtil.java