Logger.java

private static Logger eventLogger = LoggerFactory.getLogger("event-logger");
...
@Override
public void onEvent(EventLog eventLog, long sequence, boolean endOfBatch)
        throws Exception {

    String eventType = eventLog.getEventType();
    String json = eventLog.getValue();

    if (this.eventLoggingEnabled) {
        eventLogger.info(json);
    }
}

.