[Event Hubs] Fix Snippet Syntax (Azure#25684)

jsquire · web-flow · commit e01b508b573e · 2021-12-03T16:35:52.000-05:00
* [Event Hubs] Fix Snippet Syntax

The focus of these changes is to update the snippet syntax from the legacy
comment style (/*@@*/) to the compiler conditional for a few instances
that were overlooked in the initial migration.   Riding along is a fix for
a merge error that snuck into the solution file.

* Fix some spacing issues...
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs.Processor/samples/Sample05_IdentityAndSharedAccessCredentials.md b/sdk/eventhub/Azure.Messaging.EventHubs.Processor/samples/Sample05_IdentityAndSharedAccessCredentials.md
@@ -262,18 +262,20 @@ In some scenarios, it may be preferable to supplement token-based authorization
 This example illustrates parsing the fully qualified namespace and, optionally, the Event Hub name from the connection string and using it with identity-based authorization.
 
 ```C# Snippet:EventHubs_Processor_Sample05_ConnectionStringParse
-TokenCredential credential = new DefaultAzureCredential();
-
-var storageConnectionString = "<< CONNECTION STRING FOR THE STORAGE ACCOUNT >>";
-var blobContainerName = "<< NAME OF THE BLOB CONTAINER >>";
+var credential = new DefaultAzureCredential();
 
 var eventHubsConnectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";
 var eventHubName = "<< NAME OF THE EVENT HUB >>";
 var consumerGroup = "<< NAME OF THE EVENT HUB CONSUMER GROUP >>";
 
+var storageConnectionString = "<< CONNECTION STRING FOR THE STORAGE ACCOUNT >>";
+var blobContainerName = "<< NAME OF THE BLOB CONTAINER >>";
 var storageEndpoint = new BlobServiceClient(storageConnectionString).Uri;
-var blobUriBuilder = new BlobUriBuilder(storageEndpoint);
-blobUriBuilder.BlobContainerName = blobContainerName;
+
+var blobUriBuilder = new BlobUriBuilder(storageEndpoint)
+{
+    BlobContainerName = blobContainerName
+};
 
 var storageClient = new BlobContainerClient(
     blobUriBuilder.ToUri(),
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs.Processor/tests/Snippets/Sample05_IdentityAndSharedAccessCredentialsLiveTests.cs b/sdk/eventhub/Azure.Messaging.EventHubs.Processor/tests/Snippets/Sample05_IdentityAndSharedAccessCredentialsLiveTests.cs
@@ -309,26 +309,29 @@ public async Task ConnectionStringParse()
 
             #region Snippet:EventHubs_Processor_Sample05_ConnectionStringParse
 
-            TokenCredential credential = new DefaultAzureCredential();
-
-            var storageConnectionString = "<< CONNECTION STRING FOR THE STORAGE ACCOUNT >>";
-            var blobContainerName = "<< NAME OF THE BLOB CONTAINER >>";
-            /*@@*/
-            /*@@*/ storageConnectionString = StorageTestEnvironment.Instance.StorageConnectionString;
-            /*@@*/ blobContainerName = storageScope.ContainerName;
+#if SNIPPET
+            var credential = new DefaultAzureCredential();
 
             var eventHubsConnectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";
             var eventHubName = "<< NAME OF THE EVENT HUB >>";
             var consumerGroup = "<< NAME OF THE EVENT HUB CONSUMER GROUP >>";
-            /*@@*/
-            /*@@*/ eventHubsConnectionString = EventHubsTestEnvironment.Instance.EventHubsConnectionString;
-            /*@@*/ eventHubName = eventHubScope.EventHubName;
-            /*@@*/ consumerGroup = eventHubScope.ConsumerGroups.First();
-            /*@@*/ credential = EventHubsTestEnvironment.Instance.Credential;
 
+            var storageConnectionString = "<< CONNECTION STRING FOR THE STORAGE ACCOUNT >>";
+            var blobContainerName = "<< NAME OF THE BLOB CONTAINER >>";
+#else
+            var credential = EventHubsTestEnvironment.Instance.Credential;
+            var eventHubsConnectionString = EventHubsTestEnvironment.Instance.EventHubsConnectionString;
+            var eventHubName = eventHubScope.EventHubName;
+            var consumerGroup = eventHubScope.ConsumerGroups.First();
+            var storageConnectionString = StorageTestEnvironment.Instance.StorageConnectionString;
+            var blobContainerName = storageScope.ContainerName;
+#endif
             var storageEndpoint = new BlobServiceClient(storageConnectionString).Uri;
-            var blobUriBuilder = new BlobUriBuilder(storageEndpoint);
-            blobUriBuilder.BlobContainerName = blobContainerName;
+
+            var blobUriBuilder = new BlobUriBuilder(storageEndpoint)
+            {
+                BlobContainerName = blobContainerName
+            };
 
             var storageClient = new BlobContainerClient(
                 blobUriBuilder.ToUri(),
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs/Azure.Messaging.EventHubs.sln b/sdk/eventhub/Azure.Messaging.EventHubs/Azure.Messaging.EventHubs.sln
@@ -84,9 +84,6 @@ Global
 		{FB10A6B3-88DD-4296-9241-53ECDF942842}.Release|x64.ActiveCfg = Release|Any CPU
 		{FB10A6B3-88DD-4296-9241-53ECDF942842}.Release|x64.Build.0 = Release|Any CPU
 		{FB10A6B3-88DD-4296-9241-53ECDF942842}.Release|x86.ActiveCfg = Release|Any CPU
-<<<<<<< HEAD
-		{FB10A6B3-88DD-4296-9241-53ECDF942842}.Release|x86.Build.0 = Release|Any CPU		
-=======
 		{FB10A6B3-88DD-4296-9241-53ECDF942842}.Release|x86.Build.0 = Release|Any CPU
 		{79B7DF40-239D-4360-A1C3-D4F92A2E75EA}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{79B7DF40-239D-4360-A1C3-D4F92A2E75EA}.Debug|Any CPU.Build.0 = Debug|Any CPU
@@ -100,19 +97,14 @@ Global
 		{79B7DF40-239D-4360-A1C3-D4F92A2E75EA}.Release|x64.Build.0 = Release|Any CPU
 		{79B7DF40-239D-4360-A1C3-D4F92A2E75EA}.Release|x86.ActiveCfg = Release|Any CPU
 		{79B7DF40-239D-4360-A1C3-D4F92A2E75EA}.Release|x86.Build.0 = Release|Any CPU
->>>>>>> b3d9d8605d ([Event Hubs Client] Idempotent Error Handling)
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
 	EndGlobalSection
 	GlobalSection(NestedProjects) = preSolution
 		{2CFDB3D6-5CFB-428C-9C89-29DD169B5433} = {2DB233D3-E757-423C-8F8D-742B0AFF4713}
-<<<<<<< HEAD
-		{6C67B4C6-0ABF-4E10-8BAF-FCF2AD053DE3} = {2DB233D3-E757-423C-8F8D-742B0AFF4713}
-=======
 		{FB10A6B3-88DD-4296-9241-53ECDF942842} = {2DB233D3-E757-423C-8F8D-742B0AFF4713}
 		{79B7DF40-239D-4360-A1C3-D4F92A2E75EA} = {2DB233D3-E757-423C-8F8D-742B0AFF4713}
->>>>>>> b3d9d8605d ([Event Hubs Client] Idempotent Error Handling)
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {509F2EE0-3348-4506-8AC7-9945B602CB43}
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs/samples/Sample06_IdentityAndSharedAccessCredentials.md b/sdk/eventhub/Azure.Messaging.EventHubs/samples/Sample06_IdentityAndSharedAccessCredentials.md
@@ -54,7 +54,7 @@ var producer = new EventHubProducerClient(fullyQualifiedNamespace, eventHubName,
 
 try
 {
-    using var eventBatch = await producer.CreateBatchAsync();
+    using EventDataBatch eventBatch = await producer.CreateBatchAsync();
 
     for (var index = 0; index < 5; ++index)
     {
@@ -87,7 +87,7 @@ var producer = new EventHubProducerClient(fullyQualifiedNamespace, eventHubName,
 
 try
 {
-    using var eventBatch = await producer.CreateBatchAsync();
+    using EventDataBatch eventBatch = await producer.CreateBatchAsync();
 
     for (var index = 0; index < 5; ++index)
     {
@@ -120,7 +120,7 @@ var producer = new EventHubProducerClient(fullyQualifiedNamespace, eventHubName,
 
 try
 {
-    using var eventBatch = await producer.CreateBatchAsync();
+    using EventDataBatch eventBatch = await producer.CreateBatchAsync();
 
     for (var index = 0; index < 5; ++index)
     {
@@ -148,22 +148,22 @@ In some scenarios, it may be preferable to supplement token-based authorization
 This example illustrates parsing the fully qualified namespace and, optionally, the Event Hub name from the connection string and using it with identity-based authorization.
 
 ```C# Snippet:EventHubs_Sample06_ConnectionStringParse
+var credential = new DefaultAzureCredential();
+
 var connectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";
 var eventHubName = "<< NAME OF THE EVENT HUB >>";
 
 EventHubsConnectionStringProperties properties =
     EventHubsConnectionStringProperties.Parse(connectionString);
 
-TokenCredential credential = new DefaultAzureCredential();
-
 var producer = new EventHubProducerClient(
     properties.FullyQualifiedNamespace,
     properties.EventHubName ?? eventHubName,
     credential);
 
 try
 {
-    using var eventBatch = await producer.CreateBatchAsync();
+    using EventDataBatch eventBatch = await producer.CreateBatchAsync();
 
     for (var index = 0; index < 5; ++index)
     {
diff --git a/sdk/eventhub/Azure.Messaging.EventHubs/tests/Snippets/Sample06_IdentityAndSharedAccessCredentialsLiveTests.cs b/sdk/eventhub/Azure.Messaging.EventHubs/tests/Snippets/Sample06_IdentityAndSharedAccessCredentialsLiveTests.cs
@@ -4,7 +4,6 @@
 using System;
 using System.Diagnostics.CodeAnalysis;
 using System.Threading.Tasks;
-using Azure.Core;
 using Azure.Identity;
 using Azure.Messaging.EventHubs.Authorization;
 using Azure.Messaging.EventHubs.Producer;
@@ -49,7 +48,7 @@ public async Task DefaultAzureCredential()
 
             try
             {
-                using var eventBatch = await producer.CreateBatchAsync();
+                using EventDataBatch eventBatch = await producer.CreateBatchAsync();
 
                 for (var index = 0; index < 5; ++index)
                 {
@@ -101,7 +100,7 @@ public async Task SharedAccessSignature()
 
             try
             {
-                using var eventBatch = await producer.CreateBatchAsync();
+                using EventDataBatch eventBatch = await producer.CreateBatchAsync();
 
                 for (var index = 0; index < 5; ++index)
                 {
@@ -150,7 +149,7 @@ public async Task SharedAccessKey()
 
             try
             {
-                using var eventBatch = await producer.CreateBatchAsync();
+                using EventDataBatch eventBatch = await producer.CreateBatchAsync();
 
                 for (var index = 0; index < 5; ++index)
                 {
@@ -185,28 +184,27 @@ public async Task ConnectionStringParse()
             #region Snippet:EventHubs_Sample06_ConnectionStringParse
 
 #if SNIPPET
+            var credential = new DefaultAzureCredential();
+
             var connectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";
             var eventHubName = "<< NAME OF THE EVENT HUB >>";
 #else
             var connectionString = EventHubsTestEnvironment.Instance.EventHubsConnectionString;
             var eventHubName = scope.EventHubName;
+            var credential = EventHubsTestEnvironment.Instance.Credential;
 #endif
 
             EventHubsConnectionStringProperties properties =
                 EventHubsConnectionStringProperties.Parse(connectionString);
 
-            TokenCredential credential = new DefaultAzureCredential();
-            /*@@*/
-            /*@@*/ credential = EventHubsTestEnvironment.Instance.Credential;
-
             var producer = new EventHubProducerClient(
                 properties.FullyQualifiedNamespace,
                 properties.EventHubName ?? eventHubName,
                 credential);
 
             try
             {
-                using var eventBatch = await producer.CreateBatchAsync();
+                using EventDataBatch eventBatch = await producer.CreateBatchAsync();
 
                 for (var index = 0; index < 5; ++index)
                 {
diff --git a/sdk/eventhub/Microsoft.Azure.EventHubs/tests/Snippets/MigrationGuideSnippets.cs b/sdk/eventhub/Microsoft.Azure.EventHubs/tests/Snippets/MigrationGuideSnippets.cs
@@ -30,12 +30,13 @@ public class MigrationGuideSnippets
         public void CreateWithConnectionString()
         {
             #region Snippet:EventHubs_Migrate_T1_CreateWithConnectionString
-
+#if SNIPPET
             var connectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";
             var eventHubName = "<< NAME OF THE EVENT HUB >>";
-            /*@@*/
-            /*@@*/ connectionString = TestUtility.EventHubsConnectionString;
-            /*@@*/ eventHubName = "fake";
+#else
+            var connectionString = TestUtility.EventHubsConnectionString;
+            var eventHubName = "fake";
+#endif
 
             var builder = new EventHubsConnectionStringBuilder(connectionString);
             builder.EntityPath = eventHubName;
@@ -55,20 +56,20 @@ public async Task CreateWithAzureActiveDirectory()
             await using var scope = await EventHubScope.CreateAsync(1);
 
             #region Snippet:EventHubs_Migrate_T1_CreateWithAzureActiveDirectory
-
+#if SNIPPET
             var fullyQualifiedNamespace = "<< NAMESPACE (likely similar to {your-namespace}.servicebus.windows.net) >>";
             var eventHubName = "<< NAME OF THE EVENT HUB >>";
-            /*@@*/
-            /*@@*/ fullyQualifiedNamespace = new EventHubsConnectionStringBuilder(TestUtility.EventHubsConnectionString).Endpoint.ToString();
-            /*@@*/ eventHubName = scope.EventHubName;
 
             var authority = "<< NAME OF THE AUTHORITY TO ASSOCIATE WITH THE TOKEN >>";
             var aadAppId = "<< THE AZURE ACTIVE DIRECTORY APPLICATION ID TO REQUEST A TOKEN FOR >>";
             var aadAppSecret = "<< THE AZURE ACTIVE DIRECTORY SECRET TO USE FOR THE TOKEN >>";
-            /*@@*/
-            /*@@*/ authority = "";     // Needed for manual run
-            /*@@*/ aadAppId = "";      // Needed for manual run
-            /*@@*/ aadAppSecret = "";  // Needed for manual run
+#else
+            var fullyQualifiedNamespace = new EventHubsConnectionStringBuilder(TestUtility.EventHubsConnectionString).Endpoint.ToString();
+            var eventHubName = scope.EventHubName;
+            var authority = "";     // Needed for manual run
+            var aadAppId = "";      // Needed for manual run
+            var aadAppSecret = "";  // Needed for manual run
+#endif
 
             AzureActiveDirectoryTokenProvider.AuthenticationCallback authCallback =
                 async (audience, authority, state) =>
@@ -99,12 +100,13 @@ public async Task CreateWithManagedIdentity()
             await using var scope = await EventHubScope.CreateAsync(1);
 
             #region Snippet:EventHubs_Migrate_T1_ManagedIdentity
-
+#if SNIPPET
             var fullyQualifiedNamespace = "<< NAMESPACE (likely similar to {your-namespace}.servicebus.windows.net) >>";
             var eventHubName = "<< NAME OF THE EVENT HUB >>";
-            /*@@*/
-            /*@@*/ fullyQualifiedNamespace = new EventHubsConnectionStringBuilder(TestUtility.EventHubsConnectionString).Endpoint.ToString();
-            /*@@*/ eventHubName = scope.EventHubName;
+#else
+            var fullyQualifiedNamespace = new EventHubsConnectionStringBuilder(TestUtility.EventHubsConnectionString).Endpoint.ToString();
+            var eventHubName = scope.EventHubName;
+#endif
 
             EventHubClient client = EventHubClient.CreateWithManagedIdentity(
                 new Uri(fullyQualifiedNamespace),
@@ -123,12 +125,13 @@ public async Task PublishWithAutomaticRouting()
             await using var scope = await EventHubScope.CreateAsync(1);
 
             #region Snippet:EventHubs_Migrate_T1_PublishWithAutomaticRouting
-
+#if SNIPPET
             var connectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";
             var eventHubName = "<< NAME OF THE EVENT HUB >>";
-            /*@@*/
-            /*@@*/ connectionString = TestUtility.EventHubsConnectionString;
-            /*@@*/ eventHubName = scope.EventHubName;
+#else
+            var connectionString = TestUtility.EventHubsConnectionString;
+            var eventHubName = scope.EventHubName;
+#endif
 
             var builder = new EventHubsConnectionStringBuilder(connectionString);
             builder.EntityPath = eventHubName;
@@ -167,12 +170,13 @@ public async Task PublishWithAPartitionKey()
             await using var scope = await EventHubScope.CreateAsync(1);
 
             #region Snippet:EventHubs_Migrate_T1_PublishWithAPartitionKey
-
+#if SNIPPET
             var connectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";
             var eventHubName = "<< NAME OF THE EVENT HUB >>";
-            /*@@*/
-            /*@@*/ connectionString = TestUtility.EventHubsConnectionString;
-            /*@@*/ eventHubName = scope.EventHubName;
+#else
+            var connectionString = TestUtility.EventHubsConnectionString;
+            var eventHubName = scope.EventHubName;
+#endif
 
             var builder = new EventHubsConnectionStringBuilder(connectionString);
             builder.EntityPath = eventHubName;
@@ -216,12 +220,13 @@ public async Task PublishToSpecificPartition()
             await using var scope = await EventHubScope.CreateAsync(1);
 
             #region Snippet:EventHubs_Migrate_T1_PublishToSpecificPartition
-
+#if SNIPPET
             var connectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";
             var eventHubName = "<< NAME OF THE EVENT HUB >>";
-            /*@@*/
-            /*@@*/ connectionString = TestUtility.EventHubsConnectionString;
-            /*@@*/ eventHubName = scope.EventHubName;
+#else
+            var connectionString = TestUtility.EventHubsConnectionString;
+            var eventHubName = scope.EventHubName;
+#endif
 
             var builder = new EventHubsConnectionStringBuilder(connectionString);
             builder.EntityPath = eventHubName;
@@ -265,14 +270,15 @@ public async Task ReadFromSpecificPartition()
             await using var scope = await EventHubScope.CreateAsync(1);
 
             #region Snippet:EventHubs_Migrate_T1_ReadFromSpecificPartition
-
+#if SNIPPET
             var connectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";
             var eventHubName = "<< NAME OF THE EVENT HUB >>";
             var consumerGroup = "<< NAME OF THE EVENT HUB CONSUMER GROUP >>";
-            /*@@*/
-            /*@@*/ connectionString = TestUtility.EventHubsConnectionString;
-            /*@@*/ eventHubName = scope.EventHubName;
-            /*@@*/ consumerGroup = PartitionReceiver.DefaultConsumerGroupName;
+#else
+            var connectionString = TestUtility.EventHubsConnectionString;
+            var eventHubName = scope.EventHubName;
+            var consumerGroup = PartitionReceiver.DefaultConsumerGroupName;
+#endif
 
             var builder = new EventHubsConnectionStringBuilder(connectionString);
             builder.EntityPath = eventHubName;
@@ -309,20 +315,21 @@ public async Task BasicEventProcessorHost()
             await using var scope = await EventHubScope.CreateAsync(1);
 
             #region Snippet:EventHubs_Migrate_T1_BasicEventProcessorHost
-
+#if SNIPPET
             var storageConnectionString = "<< CONNECTION STRING FOR THE STORAGE ACCOUNT >>";
             var blobContainerName = "<< NAME OF THE BLOB CONTAINER >>";
-            /*@@*/
-            /*@@*/ storageConnectionString = TestUtility.StorageConnectionString;
-            /*@@*/ blobContainerName = "migragionsample";
 
             var eventHubsConnectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";
             var eventHubName = "<< NAME OF THE EVENT HUB >>";
             var consumerGroup = "<< NAME OF THE EVENT HUB CONSUMER GROUP >>";
-            /*@@*/
-            /*@@*/ eventHubsConnectionString = TestUtility.EventHubsConnectionString;
-            /*@@*/ eventHubName = scope.EventHubName;
-            /*@@*/ consumerGroup = PartitionReceiver.DefaultConsumerGroupName;
+#else
+            var storageConnectionString = TestUtility.StorageConnectionString;
+            var blobContainerName = "migragionsample";
+
+            var eventHubsConnectionString = TestUtility.EventHubsConnectionString;
+            var eventHubName = scope.EventHubName;
+            var consumerGroup = PartitionReceiver.DefaultConsumerGroupName;
+#endif
 
             var eventProcessorHost = new EventProcessorHost(
                 eventHubName,

Original file line number	Diff line number	Diff line change
`@@ -54,7 +54,7 @@ var producer = new EventHubProducerClient(fullyQualifiedNamespace, eventHubName,`
`54`	`54`
`55`	`55`	`try`
`56`	`56`	`{`
`57`		`- using var eventBatch = await producer.CreateBatchAsync();`
	`57`	`+ using EventDataBatch eventBatch = await producer.CreateBatchAsync();`
`58`	`58`
`59`	`59`	`for (var index = 0; index < 5; ++index)`
`60`	`60`	`{`
`@@ -87,7 +87,7 @@ var producer = new EventHubProducerClient(fullyQualifiedNamespace, eventHubName,`
`87`	`87`
`88`	`88`	`try`
`89`	`89`	`{`
`90`		`- using var eventBatch = await producer.CreateBatchAsync();`
	`90`	`+ using EventDataBatch eventBatch = await producer.CreateBatchAsync();`
`91`	`91`
`92`	`92`	`for (var index = 0; index < 5; ++index)`
`93`	`93`	`{`
`@@ -120,7 +120,7 @@ var producer = new EventHubProducerClient(fullyQualifiedNamespace, eventHubName,`
`120`	`120`
`121`	`121`	`try`
`122`	`122`	`{`
`123`		`- using var eventBatch = await producer.CreateBatchAsync();`
	`123`	`+ using EventDataBatch eventBatch = await producer.CreateBatchAsync();`
`124`	`124`
`125`	`125`	`for (var index = 0; index < 5; ++index)`
`126`	`126`	`{`
`@@ -148,22 +148,22 @@ In some scenarios, it may be preferable to supplement token-based authorization`
`148`	`148`	`This example illustrates parsing the fully qualified namespace and, optionally, the Event Hub name from the connection string and using it with identity-based authorization.`
`149`	`149`
`150`	`150`	```C# Snippet:EventHubs_Sample06_ConnectionStringParse
	`151`	`+var credential = new DefaultAzureCredential();`
	`152`	`+`
`151`	`153`	`var connectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";`
`152`	`154`	`var eventHubName = "<< NAME OF THE EVENT HUB >>";`
`153`	`155`
`154`	`156`	`EventHubsConnectionStringProperties properties =`
`155`	`157`	`EventHubsConnectionStringProperties.Parse(connectionString);`
`156`	`158`
`157`		`-TokenCredential credential = new DefaultAzureCredential();`
`158`		`-`
`159`	`159`	`var producer = new EventHubProducerClient(`
`160`	`160`	`properties.FullyQualifiedNamespace,`
`161`	`161`	`properties.EventHubName ?? eventHubName,`
`162`	`162`	`credential);`
`163`	`163`
`164`	`164`	`try`
`165`	`165`	`{`
`166`		`- using var eventBatch = await producer.CreateBatchAsync();`
	`166`	`+ using EventDataBatch eventBatch = await producer.CreateBatchAsync();`
`167`	`167`
`168`	`168`	`for (var index = 0; index < 5; ++index)`
`169`	`169`	`{`