fix(inputs.mqtt_consumer): Resolve could not mark message delivered (i…

…nfluxdata#14243)
jeffrey4l · Nov 3, 2023 · 9e5e74e · 9e5e74e
1 parent 7da8956
commit 9e5e74e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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()
 }