From 3196bc4c1cec8bfa0b6fc52b0468fb18461ff6b1 Mon Sep 17 00:00:00 2001 From: reimda Date: Wed, 26 Oct 2022 09:32:58 -0600 Subject: [PATCH] chore: shut down plugins gracefully to prevent race (#12102) --- plugins/inputs/kafka_consumer/kafka_consumer_test.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/plugins/inputs/kafka_consumer/kafka_consumer_test.go b/plugins/inputs/kafka_consumer/kafka_consumer_test.go index 7f6b6899c..8e327ae3c 100644 --- a/plugins/inputs/kafka_consumer/kafka_consumer_test.go +++ b/plugins/inputs/kafka_consumer/kafka_consumer_test.go @@ -470,8 +470,6 @@ func TestConsumerGroupHandler_Handle(t *testing.T) { } func TestKafkaRoundTripIntegration(t *testing.T) { - t.Skip("fails race check") - if testing.Short() { t.Skip("Skipping integration test in short mode") } @@ -574,5 +572,9 @@ func TestKafkaRoundTripIntegration(t *testing.T) { acc.Wait(len(expected)) testutil.RequireMetricsEqual(t, expected, acc.GetTelegrafMetrics()) + t.Logf("rt: shutdown") + require.NoError(t, output.Close()) + input.Stop() + t.Logf("rt: done") }