fix unit test of authentication.go

open-telemetry · Sep 6, 2024 · a35c776 · a35c776
1 parent 1c502fd
commit a35c776
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/internal/kafka/authentication_test.go b/internal/kafka/authentication_test.go
@@ -52,10 +52,11 @@ func TestAuthentication(t *testing.T) {
 	require.NoError(t, err)
 	saramaTLSCfg.Net.TLS.Config = tlscfg
 
+	ctx := context.Background()
 	saramaSASLAWSIAMOATUHConfig := &sarama.Config{}
 	saramaSASLAWSIAMOATUHConfig.Net.SASL.Enable = true
 	saramaSASLAWSIAMOATUHConfig.Net.SASL.Mechanism = sarama.SASLTypeOAuth
-	saramaSASLAWSIAMOATUHConfig.Net.SASL.TokenProvider = &AWSMSKConfig{Region: "region"}
+	saramaSASLAWSIAMOATUHConfig.Net.SASL.TokenProvider = &AWSMSKConfig{Region: "region", ctx: ctx}
 
 	tlsConfig := tls.Config{}
 	saramaSASLAWSIAMOATUHConfig.Net.TLS.Enable = true