File tree Expand file tree Collapse file tree 2 files changed +14
-1
lines changed Expand file tree Collapse file tree 2 files changed +14
-1
lines changed Original file line number Diff line number Diff line change @@ -218,16 +218,20 @@ func (c ClusterConfig) NewAdminClient(
218218 var saslUsername string
219219 var saslPassword string
220220 var secretsManagerArn string
221+
222+ overridingUserPass := false
221223 if opts .UsernameOverride != "" {
222224 log .Debugf ("Setting SASL username from override value" )
223225 saslUsername = opts .UsernameOverride
226+ overridingUserPass = true
224227 } else {
225228 saslUsername = c .Spec .SASL .Username
226229 }
227230
228231 if opts .PasswordOverride != "" {
229232 log .Debugf ("Setting SASL password from override value" )
230233 saslPassword = opts .PasswordOverride
234+ overridingUserPass = true
231235 } else {
232236 saslPassword = c .Spec .SASL .Password
233237 }
@@ -238,6 +242,15 @@ func (c ClusterConfig) NewAdminClient(
238242 } else {
239243 secretsManagerArn = c .Spec .SASL .SecretsManagerArn
240244 }
245+ if overridingUserPass {
246+ // Make sure both user and pass were provided
247+ if saslUsername == "" || saslPassword == "" {
248+ return nil , errors .New ("Both username and password are required when overriding config" )
249+ } else {
250+ log .Warn ("Username/Password override takes precedence over SecretsManagerArn" )
251+ secretsManagerArn = ""
252+ }
253+ }
241254
242255 var saslMechanism admin.SASLMechanism
243256 var err error
Original file line number Diff line number Diff line change 11package version
22
33// Version is the current topicctl version.
4- const Version = "1.19.1 "
4+ const Version = "1.19.2 "
You can’t perform that action at this time.
0 commit comments