public boolean getDrainMonitorEnabled() {
    return getBoolean(DRAIN_MONITOR_ENABLED, DRAIN_MONITOR_ENABLED_DEFAULT);
  }
Get coordinatorStreamFactory according to the configs
@return the name of coordinatorStreamFactory
samza-core/src/main/java/org/apache/samza/config/JobConfig.java