protected void sendEventToSystemProducer(EncodedLogEvent logQueueEntry) {
    metrics.logMessagesBytesSent.inc(logQueueEntry.getEntryValueSize());
    metrics.logMessagesCountSent.inc();
    systemProducer.send(SOURCE, decorateLogEvent(logQueueEntry));
  }
Helper method to send a serialized log-event to the systemProducer, and increment respective methods.
@param logQueueEntry the serialized log-event to be sent to the systemProducer
samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java