Fix Kafka AWS auth config bug (#4043)

jjcollinge · web-flow · commit 89181b7e25aa · 2025-10-01T05:30:48.000-07:00
Signed-off-by: GitHub Actions Bot &lt;action@github.com&gt;
Signed-off-by: Joni Collinge &lt;jonathancollinge@live.com&gt;
diff --git a/common/component/kafka/kafka.go b/common/component/kafka/kafka.go
@@ -295,6 +295,7 @@ func (k *Kafka) ValidateAWS(metadata map[string]string) (awsAuth.Options, error)
 	}
 
 	return awsAuth.Options{
+		Logger:                k.logger,
 		Region:                region,
 		AccessKey:             accessKey,
 		SecretKey:             secretKey,

Original file line number	Diff line number	Diff line change
`@@ -295,6 +295,7 @@ func (k *Kafka) ValidateAWS(metadata map[string]string) (awsAuth.Options, error)`
`295`	`295`	`}`
`296`	`296`
`297`	`297`	`return awsAuth.Options{`
	`298`	`+ Logger: k.logger,`
`298`	`299`	`Region: region,`
`299`	`300`	`AccessKey: accessKey,`
`300`	`301`	`SecretKey: secretKey,`