From fcb713a0a7a3fed6f84dc0cb2eacdd3d833539c0 Mon Sep 17 00:00:00 2001 From: Sven Rebhan <36194019+srebhan@users.noreply.github.com> Date: Tue, 19 Mar 2024 17:42:51 +0100 Subject: [PATCH] fix(inputs.prometheus): Initialize logger of parser (#15021) --- plugins/inputs/prometheus/prometheus.go | 1 + plugins/parsers/prometheus/parser.go | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/plugins/inputs/prometheus/prometheus.go b/plugins/inputs/prometheus/prometheus.go index 0ceb5b106..10daa5879 100644 --- a/plugins/inputs/prometheus/prometheus.go +++ b/plugins/inputs/prometheus/prometheus.go @@ -492,6 +492,7 @@ func (p *Prometheus) gatherURL(u URLAndAddress, acc telegraf.Accumulator) (map[s Header: resp.Header, MetricVersion: p.MetricVersion, IgnoreTimestamp: p.IgnoreTimestamp, + Log: p.Log, } metrics, err := metricParser.Parse(body) if err != nil { diff --git a/plugins/parsers/prometheus/parser.go b/plugins/parsers/prometheus/parser.go index 6b2291477..46884ec3b 100644 --- a/plugins/parsers/prometheus/parser.go +++ b/plugins/parsers/prometheus/parser.go @@ -38,7 +38,7 @@ func (p *Parser) Parse(data []byte) ([]telegraf.Metric, error) { data = append(data, []byte("\n")...) } case expfmt.FmtUnknown: - p.Log.Warnf("Unknown format %q... Trying to continue...", p.Header.Get("Content-Type")) + p.Log.Debugf("Unknown format %q... Trying to continue...", p.Header.Get("Content-Type")) } buf := bytes.NewBuffer(data) decoder := expfmt.NewDecoder(buf, format)