@Override
  public void start() {
    LOG.info("Starting in memory system producer for {}", systemName);
  }
Start the SystemProducer. After this method finishes it should be ready to accept messages received from the send method.
samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemProducer.java