@VisibleForTesting
  boolean readyToInitialize() {
    return LoggingContextHolder.INSTANCE.getConfig() != null;
  }
force the system producer to flush the messages
samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java