Stream RealTime data from an On Prem Microsoft Server to a Azure Data Lake.
There is a need for Real Time data to be collected from a On Prem SQL Server. This means ADF is not suitable because it only does batch. Azure Streaming Analytics only connects to Azure SQL Server and not on prem. Has anybody else encountered this and…
Debugging Data Loss in Stream Analytics to Event Hubs and ADF
My goal is to stream telemetry data from blob storage files into a Azure Data Factory database. I have set up a stream analytics job that takes data from blob storage, bins it by hour, and then passes it through an event hub with two partitions in order…
We are seeing higher than normal latencies of around 4 seconds per request when sending events to Azure Event Hub. .
We send around 500k - 600k events through Azure Event Hub per day. Over the past week, we have seen our latencies for sending events to Event Hub increase to ~4 seconds per call. I thought that perhaps we were hitting some Throughput Units. But our Event…
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…
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,…
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://learn.microsoft.com/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…