@Override
  public Serde<LoggingEvent> getSerde(String name, Config config) {
    boolean locationInfoEnabled = new Log4jSystemConfig(config).getLocationEnabled();
    return new LoggingEventJsonSerde(locationInfoEnabled);
  }
A factory that returns a Serde suitable for encoding Log4J LoggingEvents as
JSON-encoded maps.
samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerdeFactory.java