@VisibleForTesting
  void createChangelogStreams() {
    ChangelogStreamManager.createChangelogStreams(config, jobModel.getMaxChangeLogStreamPartitions());
  }
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