public void start() {
    coordinatorStreamSystemProducer.register(CoordinatorStreamWriter.SOURCE);
    coordinatorStreamSystemProducer.start();
    log.info("Started coordinator stream writer.");
  }
This method initializes the writer by starting a coordinator stream producer.
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamWriter.java