public void send(CoordinatorStreamMessage message) {
    if (coordinatorStreamProducer == null) {
      throw new UnsupportedOperationException(
          String.format("CoordinatorStreamProducer is not initialized in the CoordinatorStreamManager. "));
    }
    coordinatorStreamProducer.send(message);
  }
Sends a {@link CoordinatorStreamMessage} using the underlying system producer.

@param message message which should be sent to producer
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamManager.java