public void stop() {
    if (coordinatorStreamConsumer != null) {
      coordinatorStreamConsumer.stop();
    }
    if (coordinatorStreamProducer != null) {
      coordinatorStreamProducer.stop();
    }
  }
Stops the underlying coordinator stream producer and consumer.
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamManager.java