@VisibleForTesting
  StartpointManager createStartpointManager() {
    // This method is for easy mocking.
    return new StartpointManager(coordinatorStreamStore);
  }
Generate new JobModel when becoming a leader or the list of processor changed.
samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java