@Override
  public ClusterResourceManager getClusterResourceManager(ClusterResourceManager.Callback callback,
      SamzaApplicationState state) {
    return new MockClusterResourceManager(callback, state);
  }
Mock {@link ResourceManagerFactory} used in unit tests
samza-core/src/test/java/org/apache/samza/clustermanager/MockClusterResourceManagerFactory.java