im getting "unauthorized" status code 401 although i added the neccessary permissions
im trying to send logs from my storage to an event hub by using logic app. i added the permission "Azure Event Hubs Data Sender" to the logic app (managed identity). im getting "unauthorized" status code 401 on the last step, which is…
Cross-tenant data connection between event hub and ADX
HI Team, how to create Cross-tenant data connection between event hub and ADX using SPN authentication
How to monitor partition count currently in use for event hub namespaces?
We are trying to create an alert to notify us when our event hub namespaces are nearing partition count capacity. I have been able to find out how many partitions are allocated to an event hub namespace using KQL, but have not been able to figure out how…
Azure Event Hub Geo-Disaster recovery
Your revised version looks great! Here's a slightly refined version with minor adjustments for flow: Hi, I am interested in implementing a geo-disaster recovery mechanism for Azure Event Hub. I have reviewed the guidelines regarding primary and…
Azure Event Hubs Timeout Issue with High Throughput
Hello, a proof of concept is being conducted with Azure Event Hubs to ingest real-time data streams into storage. According to the documentation, a single Throughput Unit (TU) can handle up to 1,000 messages per second. However, in practice, with 10 TUs,…
How to Investigate Duplicate Event Processing in Event Hub
Events are being processed twice, resulting in duplicate notifications for both Email and In-App messages.
I have an application which sends table data from ibmias400 tables . How to collect messages and process it according to table names from messages and load it into delta parquet files/SQL tables and use it for reporting purposes?
I have an application which sends table data from ibmias400 tables . How to collect messages and process it according to table names from messages and load it into delta parquet files/SQL tables and use it for reporting purposes?
Unable to connect azure eventhub emulator with Communication Exception: Connection refused: no further information
I try to connect the azure eventhub emulator using connection(Endpoint=sb://localhost;EntityPath=cpc-eh-aldp-forwarderdata-int-int01;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true) string locally,…
Connect to eventhub using Managed service identity (MSI) from Azure synapse analytics using pyspark spark streaming
I am trying to write data to Azure Event Hubs from an Azure Synapse Analytics notebook in PySpark using Managed Service Identity (MSI). Could you please provide step-by-step guidance on how to achieve this, along with the necessary code? Please note, I…
Having issue while streaming data from event hub into databricks using managed identity process
I'm trying to stream data from azure event hub to azure dataframe in databricks notebook using python. I have utilized managed Identity process to utilize passwordless process. It is giving the following error message when trying to stream the data.
Event Hub from another Subscription not visible for IoT Hub data route endpoints
Im trying to pass telemetry data from an IoT Hub to an event hub residing in another subscription, under same tenant/directory. I have created a managed identity, and assigned both services to the identity with Subscription-level Owner roles and…
Some questions with the Azure kafka service
we want use Azure kafka service, some questions need your help : Azure kafka is Confluent Cloud kafka? what's difference with Apache Kafka? Is support cross-region? What configuration is needed to support cross-region? Does it support native Kafka…
Inquiry Regarding Expiration of Azure Event Hub RootManageSharedAccessKey
Hi All, When I create an Azure Event Hub, a Shared Access Policy named RootManageSharedAccessKey is automatically created. I would like to confirm whether the access key within this policy has an expiration date, or if it is permanent Thank you.
unrecognized arguments: --eventhub-name
https://zcusa.951200.xyz/en-us/azure/event-hubs/event-hubs-get-connection-string#azure-cli has --namespace-name xxx in the instructions, but when I try it on my desktop or in cloud shell, I get this error: unrecognized arguments: --eventhub-name xxx
IoT Hub Continues to Send Events After Device Deletion
Hi Everyone, I have an issue with IoT Hub, Could you help ? Events such as TwinChangeEvents and DeviceLifecycleEvents are routed from IoT Hub to Event Hub. However, after deleting the deviceId (S5_U0_15312) created in 2016, IoT Hub still sends…
View Events shows error - At least one receiver for the endpoint is created with epoch of '6'.
What is the meaning of this error and how can I resolve it? I get this error when I use "View Events" option in the "Data Explorer" in the Event Hub instance. "At least one receiver for the endpoint is created with epoch of '6',…
Azure EvenHub integration with Elasticsearch
Hello, I want to send the events on the Event Hub or Azure Service Bus to Elastic (installed on an Azure VM). There are two integrations that I found - Azure Event Hub Integration and Azure Logstash Integration. Can you help me understand how to make a…
Can't create event schema using bicep file
There is no API to create schema for a schema group. The expected code as following, resource schema 'Microsoft.EventHub/namespaces/schemagroups/schemas@2024-05-01-preview' = { parent: schemaGroup name: schemaName properties: { …
How to set up capture to AzureStorage from EventHub Avro type files
Hi, I am trying to set up Avro files capture for EventHub to be stored on Azure Storage. I have a container, granted access to it as a Storage Contributor to aforementioned EventHub. When saving, I am getting all the time Not sure if anything is wrong…
i'm using azure function and eventhub trigger so if there is any exception comes during the processing the event then offset commit or checkpointing will handled by azure function runtime or it is handled manually.
i'm using azure function and eventhub trigger so if there is any exception comes during the processing the event then offset commit or checkpointing will be handled by azure function runtime or we have to handled it manually. (if exception is throws…