public void register(String source) {
    if (coordinatorStreamConsumer != null) {
      LOG.info("Registering coordinator system stream consumer from {}.", source);
      coordinatorStreamConsumer.register();
    }
    if (coordinatorStreamProducer != null) {
      LOG.info("Registering coordinator system stream producer from {}.", source);
      coordinatorStreamProducer.register(source);
    }
  }
Register source with the coordinator stream.

@param source source to register with the coordinator stream
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamManager.java