protected Log4jSystemConfig getLog4jSystemConfig(Config config) {
    return new Log4jSystemConfig(config);
  }
force the system producer to flush the messages
samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java