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")
 }