Merge pull request #302297 from wchigit/wc/fix-java-cassandra

[Service Connector] Fix java+cassandra sample code

Author: prmerger-automator[bot]

articles/service-connector/includes/code-cosmoscassandra-me-id.md

@@ -125,7 +125,7 @@ ms.author: wchi
     </dependency>
     ```
 
-1. Get an access token for the managed identity or service principal using `azure-identity`. Use the access token and `AZURE_COSMOS_LISTKEYURL` to get the password. Get the connection information from the environment variables added by Service Connector and connect to Azure Cosmos DB for Cassandra. When using the code below, uncomment the part of the code snippet for the authentication type you want to use.
+1. Get an access token for the managed identity or service principal using `azure-identity`. Use the access token and `AZURE_COSMOS_LISTKEYURL` to get the password. Get the connection information from the environment variables added by Service Connector and connect to Azure Cosmos DB for Cassandra. When using the code below, uncomment the part of the code snippet for the authentication type you want to use. Replace `<AZURE_COSMOS_DB_ACCOUNT_LOCATION>` with the location of your Azure Cosmos DB account.
 
     ```java
     import com.datastax.oss.driver.api.core.CqlSession;
@@ -164,7 +164,9 @@ ms.author: wchi
     String token = accessToken.getToken();
 
     // Get the password.
-    HttpClient client = HttpClient.newBuilder().build();
+    HttpClient client = HttpClient.newBuilder()
+        .version(HttpClient.Version.HTTP_1_1)
+        .build();
     HttpRequest request = HttpRequest.newBuilder()
         .uri(new URI(listKeyUrl))
         .header("Authorization", "Bearer " + token)
@@ -177,9 +179,14 @@ ms.author: wchi
     
     // Connect to Azure Cosmos DB for Cassandra
     final SSLContext sc = SSLContext.getInstance("TLSv1.2");
-    CqlSession session = CqlSession.builder().withSslContext(sc)
+    sc.init(null, null, null);
+    CqlSession session = CqlSession.builder()
+        .withSslContext(sc)
         .addContactPoint(new InetSocketAddress(cassandraHost, cassandraPort)).withLocalDatacenter('datacenter1')
-        .withAuthCredentials(cassandraUsername, cassandraPassword).build();
+        .withLocalDatacenter("<AZURE_COSMOS_DB_ACCOUNT_LOCATION>") // Use the same location as your Azure Cosmos DB account
+        .withKeyspace(cassandraKeyspace)
+        .withAuthCredentials(cassandraUsername, cassandraPassword)
+        .build();
     ```
 
 ### [SpringBoot](#tab/springBoot)