@@ -404,7 +404,7 @@ func TestAccStreamRSStreamConnection_AWSLambda(t *testing.T) {
404
404
})
405
405
}
406
406
407
- func getKafkaAuthenticationConfig (mechanism , username , password , tokenEndpointUrl , clientId , clientSecret , scope , saslOauthbearerExtensions , httpsCaPem string ) string {
407
+ func getKafkaAuthenticationConfig (mechanism , username , password , tokenEndpointURL , clientID , clientSecret , scope , saslOauthbearerExtensions , httpsCaPem string ) string {
408
408
if mechanism == "PLAIN" {
409
409
return fmt .Sprintf (`authentication = {
410
410
mechanism = %[1]q
@@ -420,8 +420,7 @@ func getKafkaAuthenticationConfig(mechanism, username, password, tokenEndpointUr
420
420
scope = %[5]q
421
421
sasl_oauthbearer_extensions = %[6]q
422
422
https_ca_pem = %[7]q
423
- }` , mechanism , tokenEndpointUrl , clientId , clientSecret , scope , saslOauthbearerExtensions , httpsCaPem )
424
-
423
+ }` , mechanism , tokenEndpointURL , clientID , clientSecret , scope , saslOauthbearerExtensions , httpsCaPem )
425
424
}
426
425
427
426
func configureKafka (projectID , instanceName , connectionName , authenticationConfig , bootstrapServers , configValue , networkingConfig string , useSSL bool ) string {
@@ -524,16 +523,16 @@ func checkKafkaAttributes(
524
523
}
525
524
526
525
func checkKafkaOAuthAttributes (
527
- resourceName , instanceName , connectionName , tokenEndpointUrl , clientId , clientSecret , scope , saslOauthbearerExtensions , httpsCaPem , bootstrapServers , configValue , networkingType string , usesSSL , checkClientSecret bool ) resource.TestCheckFunc {
526
+ resourceName , instanceName , connectionName , tokenEndpointURL , clientID , clientSecret , scope , saslOauthbearerExtensions , httpsCaPem , bootstrapServers , configValue , networkingType string , usesSSL , checkClientSecret bool ) resource.TestCheckFunc {
528
527
resourceChecks := []resource.TestCheckFunc {
529
528
checkStreamConnectionExists (),
530
529
resource .TestCheckResourceAttrSet (resourceName , "project_id" ),
531
530
resource .TestCheckResourceAttr (resourceName , "connection_name" , connectionName ),
532
531
resource .TestCheckResourceAttr (resourceName , "type" , "Kafka" ),
533
532
resource .TestCheckResourceAttr (resourceName , "instance_name" , instanceName ),
534
533
resource .TestCheckResourceAttr (resourceName , "authentication.mechanism" , "OAUTHBEARER" ),
535
- resource .TestCheckResourceAttr (resourceName , "authentication.token_endpoint_url" , tokenEndpointUrl ),
536
- resource .TestCheckResourceAttr (resourceName , "authentication.client_id" , clientId ),
534
+ resource .TestCheckResourceAttr (resourceName , "authentication.token_endpoint_url" , tokenEndpointURL ),
535
+ resource .TestCheckResourceAttr (resourceName , "authentication.client_id" , clientID ),
537
536
resource .TestCheckResourceAttr (resourceName , "authentication.scope" , scope ),
538
537
resource .TestCheckResourceAttr (resourceName , "authentication.sasl_oauthbearer_extensions" , saslOauthbearerExtensions ),
539
538
resource .TestCheckResourceAttr (resourceName , "authentication.https_ca_pem" , httpsCaPem ),
0 commit comments