protected OutgoingMessageEnvelope decorateLogEvent(EncodedLogEvent logQueueEntry) {
    return new OutgoingMessageEnvelope(systemStream, keyBytes, logQueueEntry.getValue());
  }
Helper method to create an OutgoingMessageEnvelope from the serialized log event.
@param logQueueEntry message bytes
@return OutgoingMessageEnvelope that contains the message bytes along with the system stream
samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java