At first I upgraded the package "Microsoft.Azure.Functions.Worker.Extensions.EventHubs" from version 4.3.0 to 5.1.0. and I upgraded from the deprecated Microsoft.Azure.EventHubs package to Azure.Messaging.EventHubs. Then I run the C# function that return the error: 'Azure.Messaging.EventHubs: The path to an Event Hub may…
I'm trying to create an Azure Event Hub using json config and Bicep. The Event Hub namespace deploys fine, but when I try to extend the code to namespaces/eventhubs and namespaces/eventhubs/authorizationRules then I encounter an issue as I have nested…
I have a working Azure Functions app, with an Event Hub trigger. It's using Microsoft.Azure.Functions.Worker 1.10, functions runtime 4, .Net 6 and running as Isolated (not in-process). The current function signature looks like: Function("MyFunction")] public async Task Run([EventHubTrigger("my-eventhub", ConsumerGroup =…
Currently, I have a EventHub trigger function that triggers for every event and now my requirement has changed as I need to monitor 2 mins data that we receive and remove any noise from the data. So, Can we create…
When it comes to Apache Kafka, on the consumer side I know it's a pull model. What about Azure EventHubs? Are they pull or push? From what I've gathered so far unlike kafka event hubs "push" events to the listeners.…
I read that event hub has retention period up to 60days. So is it possible to query the historical data from event hub? Will it delete the processed events automatically? Assuming yes - If not so - what is the…
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…