Fix InitClientEncryption not being respected in CosmosDataSinkExtension

Co-authored-by: philnach <19275540+philnach@users.noreply.github.com>

Author: Copilot

Extensions/Cosmos/Cosmos.DataTransfer.CosmosExtension/CosmosDataSinkExtension.cs

@@ -141,9 +141,18 @@ public async Task WriteAsync(IAsyncEnumerable<IDataItem> dataItems, IConfigurati
 
             var client = CosmosExtensionServices.CreateClient(settings, DisplayName, dataSource.DisplayName);
 
-            Container container = settings.UseRbacAuth
-                ? await client.GetContainer(settings.Database, settings.Container).InitializeEncryptionAsync(cancellationToken)
-                : await CreateDatabaseAndContainerAsync(client, settings, logger, cancellationToken);
+            Container container;
+            if (settings.UseRbacAuth)
+            {
+                var cosmosContainer = client.GetContainer(settings.Database, settings.Container);
+                container = settings.InitClientEncryption
+                    ? await cosmosContainer.InitializeEncryptionAsync(cancellationToken)
+                    : cosmosContainer;
+            }
+            else
+            {
+                container = await CreateDatabaseAndContainerAsync(client, settings, logger, cancellationToken);
+            }
 
             await CosmosExtensionServices.VerifyContainerAccess(container, settings.Container, logger, cancellationToken);