From bf9c9bfe4d7f5d8c29a82c117c079065696e034f Mon Sep 17 00:00:00 2001
From: Daniel Nelson <daniel.nelson@influxdb.com>
Date: Tue, 7 Jul 2020 14:04:55 -0700
Subject: [PATCH] Fix test race in kafka_consumer (#7797)

---
 testutil/accumulator.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/testutil/accumulator.go b/testutil/accumulator.go
index b05fd464c..978fb7b38 100644
--- a/testutil/accumulator.go
+++ b/testutil/accumulator.go
@@ -212,9 +212,11 @@ func (a *Accumulator) AddTrackingMetricGroup(group []telegraf.Metric) telegraf.T
 }
 
 func (a *Accumulator) Delivered() <-chan telegraf.DeliveryInfo {
+	a.Lock()
 	if a.delivered == nil {
 		a.delivered = make(chan telegraf.DeliveryInfo)
 	}
+	a.Unlock()
 	return a.delivered
 }