public void stop() {
    if (!stopped) {
      LOG.info("stopping");
      readWriteStore.close();
      fanOutStore.close();
      stopped = true;
    } else {
      LOG.warn("already stopped");
    }
  }
Perform teardown operations. Method is idempotent.
samza-core/src/main/java/org/apache/samza/startpoint/StartpointManager.java