feat: generate credentials for Java Kafka client (#1783)

redhat-developer · Nov 15, 2022 · dd956c2 · dd956c2
1 parent 731d530
commit dd956c2
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 6 deletions.
diff --git a/pkg/cmd/serviceaccount/svcaccountcmdutil/credentials/credentials.go b/pkg/cmd/serviceaccount/svcaccountcmdutil/credentials/credentials.go
@@ -13,10 +13,11 @@ import (
 )
 
 const (
-	EnvFormat        = "env"
-	JSONFormat       = "json"
-	PropertiesFormat = "properties"
-	SecretFormat     = "secret"
+	EnvFormat            = "env"
+	JSONFormat           = "json"
+	PropertiesFormat     = "properties"
+	SecretFormat         = "secret"
+	JavaPropertiesFormat = "java-kafka-properties"
 )
 
 // Templates
@@ -28,6 +29,20 @@ var (
 	rhoas.service-account.oauthTokenUrl=%v
 	`)
 
+	templateJavaProperties = heredoc.Doc(`
+	## Generated by rhoas cli
+	sasl.mechanism=OAUTHBEARER
+	security.protocol=SASL_SSL
+
+	sasl.jaas.config=org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required \
+	clientId="%v" \
+	clientSecret="%v" ;
+
+	sasl.oauthbearer.token.endpoint.url=%v
+
+	sasl.login.callback.handler.class=org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerLoginCallbackHandler
+	`)
+
 	templateEnv = heredoc.Doc(`
 	## Generated by rhoas cli
 	RHOAS_SERVICE_ACCOUNT_CLIENT_ID=%v
@@ -68,7 +83,7 @@ func GetDefaultPath(outputFormat string) (filePath string) {
 	switch outputFormat {
 	case EnvFormat:
 		filePath = ".env"
-	case PropertiesFormat:
+	case PropertiesFormat, JavaPropertiesFormat:
 		filePath = "credentials.properties"
 	case JSONFormat:
 		filePath = "credentials.json"
@@ -111,6 +126,8 @@ func getFileFormat(output string) (format string) {
 		format = templateJSON
 	case SecretFormat:
 		format = templateSecret
+	case JavaPropertiesFormat:
+		format = templateJavaProperties
 	}
 
 	return format

diff --git a/pkg/cmd/serviceaccount/svcaccountcmdutil/svcaccount_util.go b/pkg/cmd/serviceaccount/svcaccountcmdutil/svcaccount_util.go
@@ -5,5 +5,5 @@ import (
 )
 
 var (
-	CredentialsOutputFormats = []string{credentials.EnvFormat, credentials.JSONFormat, credentials.PropertiesFormat, credentials.SecretFormat}
+	CredentialsOutputFormats = []string{credentials.EnvFormat, credentials.JSONFormat, credentials.PropertiesFormat, credentials.SecretFormat, credentials.JavaPropertiesFormat}
 )
-Original file line number
+Diff line change
@@ Expand Up / @@ -5,5 +5,5 @@ import ( @@
     )
     var (
-    	CredentialsOutputFormats = []string{credentials.EnvFormat, credentials.JSONFormat, credentials.PropertiesFormat, credentials.SecretFormat}
+    	CredentialsOutputFormats = []string{credentials.EnvFormat, credentials.JSONFormat, credentials.PropertiesFormat, credentials.SecretFormat, credentials.JavaPropertiesFormat}
     )