protected String getStreamName(String jobName, String jobId) {
    if (jobName == null) {
      throw new SamzaException("job name is null. Please specify job.name");
    }
    if (jobId == null) {
      jobId = "1";
    }
    String streamName = "__samza_" + jobName + "_" + jobId + "_logs";
    return streamName.replace("-", "_");
  }
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