@Override
  public void stop() {
    LOG.info("Stopping in memory system consumer...");
  }
Tells the SystemConsumer to close all connections, release all resource,
and shut down everything. The SystemConsumer will not be used again after
stop is called.
samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemConsumer.java