fix: add missing close for kafka client

Signed-off-by: Ladislav Macoun <ladislavmacoun@gmail.com>
testcontainers · Aug 2, 2023 · b3ecfa1 · b3ecfa1
1 parent 6286fa8
commit b3ecfa1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/modules/redpanda/redpanda_test.go b/modules/redpanda/redpanda_test.go
@@ -36,6 +36,7 @@ func TestRedpanda(t *testing.T) {
 		kgo.SeedBrokers(seedBroker),
 	)
 	require.NoError(t, err)
+	defer kafkaCl.Close()
 
 	kafkaAdmCl := kadm.NewClient(kafkaCl)
 	metadata, err := kafkaAdmCl.Metadata(ctx)