From e6c04b1c967beb68a2110cbb6aecd4b1ee154ef9 Mon Sep 17 00:00:00 2001 From: Daniel Lavie Date: Mon, 9 Sep 2024 18:29:55 +0300 Subject: [PATCH] USMON-1152: Remove Kafka monitor tests optimization (#29143) --- pkg/network/usm/kafka_monitor_test.go | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/pkg/network/usm/kafka_monitor_test.go b/pkg/network/usm/kafka_monitor_test.go index bbcedaecb2be6..1c3c5e12702ca 100644 --- a/pkg/network/usm/kafka_monitor_test.go +++ b/pkg/network/usm/kafka_monitor_test.go @@ -529,19 +529,17 @@ func (s *KafkaProtocolParsingSuite) testKafkaProtocolParsing(t *testing.T, tls b require.NoError(t, proxy.WaitForConnectionReady(unixPath)) cfg := getDefaultTestConfiguration(tls) - monitor := newKafkaMonitor(t, cfg) - if tls && cfg.EnableGoTLSSupport { - utils.WaitForProgramsToBeTraced(t, "go-tls", proxyProcess.Process.Pid, utils.ManualTracingFallbackEnabled) - } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { t.Cleanup(func() { for _, client := range tt.context.clients { client.Client.Close() } - cleanProtocolMaps(t, "kafka", monitor.ebpfProgram.Manager.Manager) }) - + monitor := newKafkaMonitor(t, cfg) + if tls && cfg.EnableGoTLSSupport { + utils.WaitForProgramsToBeTraced(t, "go-tls", proxyProcess.Process.Pid, utils.ManualTracingFallbackEnabled) + } tt.testBody(t, &tt.context, monitor) }) }