I am trying to create a function app on Azure with an Event Hub trigger using a managed identity. I seem to have created everything so that all the references resolve, but when I send a message to the event…
I am trying to use azure-sdk-for-cpp to connect to Azure Event Hub. But it is not working, I get error "Could not open Claims Based Security object." I am following samples in the sources. I have just this simple code…
We are using Azure Event Hub (EH). We were testing a retry policy, to see what happens when EH doesn't have enough TUs to handle the load (both receiving and sending). We sent 3M events (in batches of 1K) to…
Per the azure docs, VM and cluster size: Streaming ingestion performance and capacity scales with increased VM and cluster sizes. The number of concurrent ingestion requests is limited to six per core. My current setup is as follows: I have…
When using Azure self-hosted agent deployed on Kubernetes I face the following error: [Error]2024-06-14T11:28:08.719 [EventHubSendFailed], exception: System.Net.Sockets.SocketException (111): Connection refused at Microsoft.Azure.EventHubs.Amqp.AmqpEventHubClient.CreateConnectionAsync(TimeSpan timeout) at Microsoft.Azure.Amqp.FaultTolerantAmqpObject`1.OnCreateAsync(TimeSpan timeout) at Microsoft.Azure.Amqp.Singleton`1.GetOrCreateAsync(TimeSpan timeout) at Microsoft.Azure.Amqp.Singleton`1.GetOrCreateAsync(TimeSpan timeout) at Microsoft.Azure.EventHubs.Amqp.AmqpEventDataSender.CreateLinkAsync(TimeSpan timeout) at Microsoft.Azure.Amqp.FaultTolerantAmqpObject`1.OnCreateAsync(TimeSpan timeout) at Microsoft.Azure.Amqp.Singleton`1.GetOrCreateAsync(TimeSpan…
Similar to a previous question related to reading logs from Azure Storage Accounts for Fluentd/Fluentbit, I am searching for a more direct way to read logs from Azure Storage Accounts into Loki. When searching, I found Amazon S3 plugins for…
Say there are 32 partitions in my Azure eventhub. I have a consumer trying to read 32 partitions and do checkpointing. But sometimes, the incoming messages to the eventhub might scale up. In order to manage the scale up, I…
I have an event schema stored in JSON format in Azure Event Hubs Schema Registry. I need to read that schema in my C# code, without hard coding the schema in the code. Schema needs to be read into a…
I am trying to raise an exception for an constructor method of EventHubBufferedProducerClient but its not working as expected. Am I missing something here. My class method: import { EventHubBufferedProducerClient } from '@azure/event-hubs'; import { logger } from '../logger'; this.producer…
Mysql DB with Java front end sending compressed and encrypted messaged to eventhub. All fine here. EventHub Capture is every 5 mins sending Avro with all messages to Storage account. For maintenance and upgrades it is sometimes necessary to pause…