diff --git a/plugins/outputs/mqtt/topic_name_generator.go b/plugins/outputs/mqtt/topic_name_generator.go index 8c9369b08..c51084450 100644 --- a/plugins/outputs/mqtt/topic_name_generator.go +++ b/plugins/outputs/mqtt/topic_name_generator.go @@ -5,6 +5,8 @@ import ( "strings" "text/template" + "github.com/Masterminds/sprig/v3" + "github.com/influxdata/telegraf" ) @@ -17,7 +19,7 @@ type TopicNameGenerator struct { } func NewTopicNameGenerator(topicPrefix, topic string) (*TopicNameGenerator, error) { - tt, err := template.New("topic_name").Parse(topic) + tt, err := template.New("topic_name").Funcs(sprig.TxtFuncMap()).Parse(topic) if err != nil { return nil, err }