protected Config getConfig() {
    Config config = LoggingContextHolder.INSTANCE.getConfig();
    // Make system producer drop producer errors for StreamAppender
    return new MapConfig(config, ImmutableMap.of(TaskConfig.DROP_PRODUCER_ERRORS, "true"));
  }
This should only be called after verifying that the {@link LoggingContextHolder} has the config.
samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java