public MockCoordinatorStreamSystemFactory.MockCoordinatorStreamSystemConsumer getMockCoordinatorStreamSystemConsumer() {
    return systemFactory.getCoordinatorStreamSystemConsumer(config, null);
  }
<p>
Instantiates and initializes a {@link CoordinatorStreamStore} based upon the provided configuration.

Primarily used for testing the metadata read/write flows in ApplicationMaster.
</p>
samza-core/src/test/java/org/apache/samza/coordinator/metadatastore/CoordinatorStreamStoreTestUtil.java