protected static 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("-", "_");
  }
This should only be called after verifying that the {@link LoggingContextHolder} has the config.
samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java