public Set<CoordinatorStreamMessage> getBootstrappedStream(String source) {
    if (coordinatorStreamConsumer == null) {
      throw new UnsupportedOperationException(
          String.format("CoordinatorStreamConsumer is not initialized in the CoordinatorStreamManager. "));
    }
    return coordinatorStreamConsumer.getBootstrappedStream(source);
  }
Returns a set of messages from the bootstrapped stream for a given source.

@param source the source of the given messages
@return a set of {@link CoordinatorStreamMessage} if messages exists for the given source, else an empty set
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamManager.java