private FaultDomainManagerFactory getFaultDomainManagerFactory(final ClusterManagerConfig clusterManagerConfig) {
    final String faultDomainManagerFactoryClass = clusterManagerConfig.getFaultDomainManagerClass();
    final FaultDomainManagerFactory factory;

    try {
      factory = ReflectionUtil.getObj(faultDomainManagerFactoryClass, FaultDomainManagerFactory.class);
    } catch (Exception e) {
      LOG.error("Error creating the fault domain manager.", e);
      throw new SamzaException(e);
    }
    return factory;
  }
Returns an instantiated {@link FaultDomainManagerFactory} from a {@link ClusterManagerConfig}. The
{@link FaultDomainManagerFactory} is used to return an implementation of a {@link FaultDomainManager}

@param clusterManagerConfig, the cluster manager config to parse.
samza-core/src/main/java/org/apache/samza/clustermanager/ContainerProcessManager.java