I'm seeing multi-second pauses in the event stream, even reading from the retention pool. Here's the main nugget of EH setup: BlobContainerClient storageClient = new BlobContainerClient(blobcon, BLOB_NAME); RTMTest.eventProcessor = new EventProcessorClient(storageClient, consumerGroup, ehubcon, EVENTHUB_NAME); And then the do nothing processor:…
I have a EventHub trigger function app using Elastic Premium tier and I'm getting a bottleneck on the EventHub side because the function doesn't scale more than 20 instances(Maximum of Minimum Instances Always Ready) to process messages, even reaching a…
Is it possible that 2 azure functions can get triggered by one eventhub? One azure function will write its data to database1 and the other azure function writes its data to database2 [FunctionName("EventToDB1")] public async System.Threading.Tasks.Task Run([EventHubTrigger("eventhub", Connection = "Debezium")]…
I'm exploring using azure event hub as an event consumer. So my .NET application sends events to the azure event hub. The event hub by default has 4 partitions. I want the events to be stored in the azure blob…
I am writing a pub/sub implementation which uses Azure EventHub as the underlying event ingestion service. In my application, the publishers will publish events to a particular EventHub partition and the consumers who are subscribed to that particular partition will…
I have JSON files that at the end of the day should be inserted to SQL Database. To explain what I mean, let's assume the JSON looks like this:{ name : "John", surname : "Smith", movie: "Snatch" } And database…
What is the way we can disable public network access using Terrform for Azure Event Hub I selected options public_network_access_enabled as false and public_network_access as false under network_rulesset block and following error "public_network_access_enabled" is not expected here. I am not…
I am trying to import following: from azure.eventhub import EventData from azure.eventhub.aio import EventHubProducerClient from azure.eventhub.exceptions import EventHubError I get error: from azure.eventhub import EventData Traceback (most recent call last): File "<stdin>", line 1, in <module> File "/Library/Frameworks/Python.framework/Versions/3.10/lib/python3.10/site-packages/azure/eventhub/__init__.py", line 5,…
I have a blob storage that has 2 Containers called input and output. when a file gets uploaded to input then a Function app (Blobtrigger) would work on it and save the result in output folder. right now i need…
I am currently working on understanding Event Hub along with Azure Function. I have checked out event driven scaling which mentions about the scale controller. But none of the azure documents I referred gave out the logic behind scale controller…