{"type":"doc","content":[{"type":"panel","attrs":{"panelType":"info"},"content":[{"type":"paragraph","content":[{"text":"For the majority of production scenarios, it is recommended that the ","type":"text"},{"text":"Event Processor Client","type":"text","marks":[{"type":"strong"}]},{"text":" be used for reading and processing events. The processor is intended to provide a robust experience for processing events across all partitions of an Event Hub in a performant and fault tolerant manner : ","type":"text"},{"text":"azure-sdk-for-net/README.md at main · Azure/azure-sdk-for-net · GitHub","type":"text","marks":[{"type":"link","attrs":{"href":"https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/eventhub/Azure.Messaging.EventHubs/README.md"}}]}]}]},{"type":"paragraph"},{"type":"codeBlock","attrs":{"language":"csharp"},"content":[{"text":"var cancellationSource = new CancellationTokenSource();\ncancellationSource.CancelAfter(TimeSpan.FromSeconds(45));\n\nvar storageConnectionString = \"<< CONNECTION STRING FOR THE STORAGE ACCOUNT >>\";\nvar blobContainerName = \"<< NAME OF THE BLOB CONTAINER >>\";\n\nvar eventHubsConnectionString = \"<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>\";\nvar eventHubName = \"<< NAME OF THE EVENT HUB >>\";\nvar consumerGroup = \"<< NAME OF THE EVENT HUB CONSUMER GROUP >>\";\n\nTask processEventHandler(ProcessEventArgs eventArgs) => Task.CompletedTask;\nTask processErrorHandler(ProcessErrorEventArgs eventArgs) => Task.CompletedTask;\n\nvar storageClient = new BlobContainerClient(storageConnectionString, blobContainerName);\nvar processor = new EventProcessorClient(storageClient, consumerGroup, \n eventHubsConnectionString, eventHubName);\n\nprocessor.ProcessEventAsync += processEventHandler;\nprocessor.ProcessErrorAsync += processErrorHandler;\n\nawait processor.StartProcessingAsync();\n\ntry\n{\n // The processor performs its work in the background; block until cancellation\n // to allow processing to take place.\n\n await Task.Delay(Timeout.Infinite, cancellationSource.Token);\n}\ncatch (TaskCanceledException)\n{\n // This is expected when the delay is canceled.\n}\n\ntry\n{\n await processor.StopProcessingAsync();\n}\nfinally\n{\n // To prevent leaks, the handlers should be removed when processing is complete.\n\n processor.ProcessEventAsync -= processEventHandler;\n processor.ProcessErrorAsync -= processErrorHandler;\n}","type":"text"}]}],"version":1}

Browser not supported