From 9e5e74e25836655396ff8f7e7bb6de6043407467 Mon Sep 17 00:00:00 2001 From: Joshua Powers Date: Fri, 3 Nov 2023 07:39:12 -0600 Subject: [PATCH] fix(inputs.mqtt_consumer): Resolve could not mark message delivered (#14243) --- plugins/inputs/mqtt_consumer/mqtt_consumer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/plugins/inputs/mqtt_consumer/mqtt_consumer.go b/plugins/inputs/mqtt_consumer/mqtt_consumer.go index dafcc9e35..69aa74a0a 100644 --- a/plugins/inputs/mqtt_consumer/mqtt_consumer.go +++ b/plugins/inputs/mqtt_consumer/mqtt_consumer.go @@ -325,8 +325,8 @@ func (m *MQTTConsumer) onMessage(_ mqtt.Client, msg mqtt.Message) { } } } - id := m.acc.AddTrackingMetricGroup(metrics) m.messagesMutex.Lock() + id := m.acc.AddTrackingMetricGroup(metrics) m.messages[id] = msg m.messagesMutex.Unlock() }