@Override
              public <T> void gauge(Gauge<T> gauge) {
                groupMsg.put(name, gauge.getValue());
              }
MetricsSnapshotReporter is a generic metrics reporter that sends metrics to a stream.

jobName // my-samza-job
jobId // an id that differentiates multiple executions of the same job
taskName // container_567890
host // eat1-app128.gird
version // 0.0.1
blacklist // Regex of metrics to ignore when flushing
samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshotReporter.java