allow specifying scopes in oauth config

birdayz · Mar 1, 2024 · 0e38e57 · 0e38e57
1 parent 0ccb57e
commit 0e38e57
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 8 deletions.
diff --git a/cmd/kaf/oauth.go b/cmd/kaf/oauth.go
@@ -55,6 +55,7 @@ func newTokenProvider() *tokenProvider {
 					ClientID:     cluster.SASL.ClientID,
 					ClientSecret: cluster.SASL.ClientSecret,
 					TokenURL:     cluster.SASL.TokenURL,
+					Scopes:       cluster.SASL.Scopes,
 				},
 				staticToken: false,
 			}

diff --git a/examples/sasl_ssl_oauth.yaml b/examples/sasl_ssl_oauth.yaml
@@ -7,6 +7,9 @@ clusters:
     clientID: my_client_oauth
     clientSecret: my_secret_oauth
     tokenURL: https//some.token.endpoint.com/token
+    scopes:
+      - scope1
+      - scope2
   TLS: 
     insecure: true
   security-protocol: SASL_SSL
diff --git a/pkg/config/config.go b/pkg/config/config.go
@@ -10,14 +10,15 @@ import (
 )
 
 type SASL struct {
-	Mechanism    string `yaml:"mechanism"`
-	Username     string `yaml:"username"`
-	Password     string `yaml:"password"`
-	ClientID     string `yaml:"clientID"`
-	ClientSecret string `yaml:"clientSecret"`
-	TokenURL     string `yaml:"tokenURL"`
-	Token        string `yaml:"token"`
-	Version      int16  `yaml:"version"`
+	Mechanism    string   `yaml:"mechanism"`
+	Username     string   `yaml:"username"`
+	Password     string   `yaml:"password"`
+	ClientID     string   `yaml:"clientID"`
+	ClientSecret string   `yaml:"clientSecret"`
+	TokenURL     string   `yaml:"tokenURL"`
+	Scopes       []string `yaml:"scopes"`
+	Token        string   `yaml:"token"`
+	Version      int16    `yaml:"version"`
 }
 
 type TLS struct {