diff --git a/internal/models/running_output.go b/internal/models/running_output.go index 713c28cce..a0d1f6b03 100644 --- a/internal/models/running_output.go +++ b/internal/models/running_output.go @@ -105,12 +105,13 @@ func (ro *RunningOutput) AddMetric(m telegraf.Metric) { tags := m.Tags() fields := m.Fields() t := m.Time() + tp := m.Type() if ok := ro.Config.Filter.Apply(name, fields, tags); !ok { ro.MetricsFiltered.Incr(1) return } // error is not possible if creating from another metric, so ignore. - m, _ = metric.New(name, tags, fields, t) + m, _ = metric.New(name, tags, fields, t, tp) } ro.metrics.Add(m)