private SystemStream getCoordinatorSystemStream(Config config) {
    assertNotNull(config.get("job.coordinator.system"));
    assertNotNull(config.get("job.name"));
    return new SystemStream(config.get("job.coordinator.system"), CoordinatorStreamUtil.getCoordinatorStreamName(config.get("job.name"),
        config.get("job.id") == null ? "1" : config.get("job.id")));
  }
Returns a consumer that sends all configs to the coordinator stream.

@param config Along with the configs, you can pass checkpoints and changelog stream messages into the stream.
              The expected pattern is cp:source:taskname -> ssp,offset for checkpoint (Use sspToString util)
              ch:source:taskname -> changelogPartition for changelog
              Everything else is processed as normal config
samza-core/src/test/java/org/apache/samza/coordinator/stream/MockCoordinatorStreamSystemFactory.java