Refactor by comments

Author: LijieZhang1998

.changelog/3680.txt

@@ -1,3 +1,11 @@
 ```release-note:enhancement
-resource/mongodbatlas_stream_connection: Add new authentication mechanism(OIDC) to the Kafka connection
+resource/mongodbatlas_stream_connection: Adds new authentication mechanism(OIDC) to the Kafka connection
+```
+
+```release-note:enhancement
+data-source/mongodbatlas_stream_connection: Adds new authentication mechanism(OIDC) to the Kafka connection
+```
+
+```release-note:enhancement
+data-source/mongodbatlas_stream_connections: Adds new authentication mechanism(OIDC) to the Kafka connection
 ```

docs/resources/stream_connection.md

@@ -180,6 +180,12 @@ If `type` is of value `Https` the following additional attributes are defined:
 * `mechanism` - Style of authentication. Can be one of `PLAIN`, `SCRAM-256`, or `SCRAM-512`.
 * `username` - Username of the account to connect to the Kafka cluster.
 * `password` - Password of the account to connect to the Kafka cluster.
+* `token_endpoint_url` -  OAUTH issuer(IdP provider) token endpoint HTTP(S) URI used to retrieve the token.
+* `client_id` - Public identifier for the Kafka client.
+* `client_secret` - Secret known only to the Kafka client and the authorization server.
+* `scope` - Kafka clients use this to specify the scope of the access request to the broker.
+* `sasl_oauthbearer_extensions` - Additional information to be provided to the Kafka broker.
+* `https_ca_pem` - The CA certificates as a PEM string.
 
 ### Security
 

internal/service/streamconnection/resource_stream_connection_test.go

@@ -108,18 +108,13 @@ func testCaseKafkaPlaintext(t *testing.T, nameSuffix string) *resource.TestCase
 }
 
 func TestAccStreamRSStreamConnection_kafkaOAuthBearer(t *testing.T) {
-	testCase := testCaseKafkaOAuthBearer(t, "")
-	resource.ParallelTest(t, *testCase)
-}
-
-func testCaseKafkaOAuthBearer(t *testing.T, nameSuffix string) *resource.TestCase {
 	t.Helper()
 	var (
 		projectID, instanceName = acc.ProjectIDExecutionWithStreamInstance(t)
-		connectionName          = "kafka-conn-oauthbearer" + nameSuffix
+		connectionName          = "kafka-conn-oauthbearer"
 	)
 
-	return &resource.TestCase{
+	testCase := &resource.TestCase{
 		PreCheck:                 func() { acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             CheckDestroyStreamConnection,
@@ -149,6 +144,7 @@ func testCaseKafkaOAuthBearer(t *testing.T, nameSuffix string) *resource.TestCas
 			},
 		},
 	}
+	resource.ParallelTest(t, *testCase)
 }
 
 func TestAccStreamRSStreamConnection_kafkaNetworkingVPC(t *testing.T) {