@Override
  public void onCoordinatorFailure(Throwable t) {
    LOG.error("Failure in coordinator, allowing shutdown to begin", t);
    this.waitForShutdownLatch.countDown();
  }
There is currently no use case for bubbling up this exception, so just log the error and allow shutdown for now. If
we get a future use case where it is useful to bubble up the exception, then we can update this class.
samza-core/src/main/java/org/apache/samza/coordinator/NoProcessorJobCoordinatorListener.java