Guidance on how to use Service Principal with Certificate to Authorize for EventHub Stream Read
I found this documentation https://github.com/Azure/azure-event-hubs-spark/blob/master/docs/use-aad-authentication-to-connect-eventhubs.md online on how to use service principal with certificate to use spark stream read from EventHubs, I want to do this…
How to remove the Server header from the response of an Event Hub?
I'm working with an Event Hub and I need to remove the Server header from the response. Is there a way to achieve this? I've attached a screenshot of the header for reference.
How to add a new field with a different record type using Avro in the schema registry?
Hi all, Can another record be used as the type field in the Avro schema? Example: Existed schema: { "type": "record", "name": "Foo", "namespace": "com.example", …
Migrating from Microsoft.Azure.EventHubs to Azure.Messaging.EventHubs . What do i need to do to make sure new SDK deployment picks up from checkpoint made by older SDK
Migrating from Microsoft.Azure.EventHubs to Azure.Messaging.EventHubs . Read from docs online that new SDK doesnt support old checkpointing format . What do i need to do to make sure new SDK deployment picks up from checkpoint made by older SDK
Event hub event triggered azure function not triggering/consuming all incoming events to event hub
Hi! I have a Azure function app of type Python which is event hub event triggered. The issue I am having is that it is partly consuming the incoming events to the event hub, but not all of them. My event hub is getting in events from a IoT hub. The…
integrate dynamics crm to Azure event Hub
Hi, I would like to connect our Dynamics CRM to an Azure event hub, that create an event each time we create a changes in dynamic. Can somone help me
Cannot delete event hubs with an active incoming events source
Hello, We enabled Entra ID logs to send to Event Hub, and when we would need to change configuration in our terraform modules, I change it and try to deploy via Azure DevOps pipelines. Everything worked until April end, but just before the Memorial Day…
Databricks not sending audit logs to event hub
Hi, I'm trying to push all the logs from databricks using the diagnostic tool to event hub but is not working, it didn't push anything. I'm using the root access policy and also already created the eventhub name, what else I'm probably missing? Thanks in…
About Disaster Recovery on Event Hubs + Functions
Hi, I'm facing an architectural challenge. I have: A Blob Storage where files will be landing A Function environment where one functions gets executed every time a file is uploaded. This is done via Event Grid notification source on Blob trigger An…
Receive change notifications through Azure Event Hubs
Hi All, I have a little inquiry regarding ‘Receive change notifications through Azure Event Hubs’. As you know, we load Azure Databricks Diagnostic logs (plus a few system tables via Azure EventGrid) into Azure EventHub, which we then consume into ADX…
Ingestion of Security Events
Good afternoon, Was not sure if anyone else has seen this before. We have a few clients that are getting abnormal ingestion of security events coming from the DC. Event ID 4661 in this case. We don't want to disable the event as it is important but we do…
Azure function event hub trigger executes after delay of about 5-10 seconds
I have an Azure Function v4 .NET 6 isolated app with an HTTP trigger function that writes events to an event hub. Another event hub triggered function in the same app listens to those events, performs some manipulation, and publishes them again to…
About Event Hubs partitions
Hi, I'm facing a challenge and a colleague of mine suggested to me to use partitions on Event Hubs. So, I've reading a lot and have some questions: ¿How are partitions related to Event Hub capacity? Let's suppose an Standard Tier with 5 TU ... ¿How is…
How are PUs assigned/distributed in azure event hub premium tier ?
Hi We have 15+ eventhub in a namespace, each namespace has varying partitions, the problem we are having are seeing is we are able to pull only 1TB per an hour, which the limits as per eventhub as higher than these. We are consuming using logstash…
We are not getting data in azure data lake Service v2 storage's container.
Hello, We are getting data in the Azure event hub sink through the POSTGRES SQL database but we are not getting files in the container which we have configured in an ADLS GEN 2 and while configuring we have an encounter that we are using a free…
Event Hub namespace not resolving with private endpoint's private IP
Hi folks, We've got some Event Hub name spaces and we have created private endpoints for them. We have kept the DNS configurations in a centralized Private DNS zone. But the namespaces don't resolve with the private IP rather they do with the public IP…
Best practice to manage device logs with IoT Hub
Hello, I was wondering if there are any best practices for managing logs generated by IoT devices. Currently, our devices generate logs in text files, and we thought the easiest way to manage these logs is to upload the text files to a storage account…
Failed to connect to Azure event hub(AEH) from Java using kafka client
It gets disconnected with following error when trying to connect to Azure event hub(AEH) from Java using kafka client. 2024-05-21 16:03:23.991 DEBUG 44 --- [ntainer#2-0-C-1] o.a.k.common.network.SslTransportLayer : [SslTransportLayer channelId=-1…
Creating an EventHub with capture configuration using Bicep script fails saying the user does not have the required data plane write permissions
I'm running a bicep script to create a couple of resources in my resource group. When it comes to event hub, I would like to use the capture functionality to store events inside a storage account gen 2. The bicep script is running from DevOps pipeline…
How to retrieve all Schema Versions from a given Schema Group, Schema in EventHub.
Hi, I am trying to access Schema Registry of a Event Hub Namespace. I want to be able to read all the versions of a SchemaDefinitions inside a known SchemaGroup and SchemaName. I know that there are SchemaRegistryClients(Azure class) provided in Azure…