From 76e7b57fcd1cd3cf61891020b94ec7ffa7407265 Mon Sep 17 00:00:00 2001
From: Daniel Nelson <daniel.nelson@influxdb.com>
Date: Fri, 6 Sep 2019 12:35:33 -0700
Subject: [PATCH] Fix could not mark message delivered error in kafka_consumer
 (#6363)

---
 plugins/inputs/kafka_consumer/kafka_consumer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/plugins/inputs/kafka_consumer/kafka_consumer.go b/plugins/inputs/kafka_consumer/kafka_consumer.go
index 2703bb52d..997988ca6 100644
--- a/plugins/inputs/kafka_consumer/kafka_consumer.go
+++ b/plugins/inputs/kafka_consumer/kafka_consumer.go
@@ -360,8 +360,8 @@ func (h *ConsumerGroupHandler) Handle(session sarama.ConsumerGroupSession, msg *
 		}
 	}
 
-	id := h.acc.AddTrackingMetricGroup(metrics)
 	h.mu.Lock()
+	id := h.acc.AddTrackingMetricGroup(metrics)
 	h.undelivered[id] = Message{session: session, message: msg}
 	h.mu.Unlock()
 	return nil