Fix could not mark message delivered error in kafka_consumer (#6363)

2019-09-06 12:35:33 -07:00
parent be7c71a39b
commit 76e7b57fcd
1 changed files with 1 additions and 1 deletions
--- 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