@Override
  public void close() {
    try {
      LOG.info("Stopping the coordinator stream system consumer.");
      systemAdmin.stop();
      systemProducer.stop();
      systemConsumer.stop();
    } catch (Exception e) {
      LOG.error("Exception occurred when closing the metadata store:", e);
    }
  }
An implementation of the {@link MetadataStore} interface where the metadata of the samza job is stored in coordinator stream.

This class is thread safe.

It is recommended to use {@link NamespaceAwareCoordinatorStreamStore}. This will enable the single CoordinatorStreamStore connection
to be shared by the multiple {@link NamespaceAwareCoordinatorStreamStore} instances.
samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/CoordinatorStreamStore.java