@Override
  public void start() {
    LOG.info("Starting in memory system consumer...");
  }
Tells the SystemConsumer to connect to the underlying system, and prepare
to begin serving messages when poll is invoked.
samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemConsumer.java