We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a1ed427 commit 43d2c9cCopy full SHA for 43d2c9c
pkg/cmd/kafka/acl/admin/admin.go
@@ -61,11 +61,13 @@ func NewAdminACLCommand(f *factory.Factory) *cobra.Command {
61
return err
62
}
63
64
- if !cfg.HasKafka() {
+ instanceID, ok := cfg.GetKafkaIdOk()
65
+
66
+ if !ok {
67
return opts.localizer.MustLocalizeError("kafka.acl.common.error.noKafkaSelected")
68
69
- opts.kafkaID = cfg.Services.Kafka.ClusterID
70
+ opts.kafkaID = instanceID
71
72
// check if priincipal is provided
73
if userID == "" && serviceAccount == "" && !allAccounts {
0 commit comments