I'm trying to find an example of Custom Checkpoint Manager in JAVA, that can store checkpoint data in a local folder. Basically, I'm building a java application that reads data from azure event hu...

Perhaps a rather simple question, yet I couldn't find the answers after doing some searching. After I have send an event to an Azure event Hub (via the Java code), how could I check back in the Azu...

Is there docker image for running in place of an Azure Event Hub in a Test or CI environment? I want to be able to stand up a full stack with mock event hubs running as docker containers, how are ...

Scenario I create an eventhub on Jan 1st 2018. My eventhub retention period is set to be 1 day. I enable the "capture", leaving the default capture parameters of every 5 mins or 300 mb, feature ...

I am looking to start a new project using Azure Event Hubs. Part of the project is a set of integration tests that can be run from any development machine (plus CI). In the past, I've used the loca...

I am trying to create streaming from eventhub using delta live tables, but I am having trouble installing the library . Is it possible to install maven library using Delta Live tables using sh /pip...

I'm leveraging services of the Azure SDK to log telemetry data to Azure Event Hubs. My client application calls an API endpoint which instantiates the EventHubProducerClient to log data to Event Hu...

Event Hubs don't let you store messages longer than 7 (maybe up to 30) days. What is Azure's suggested architecture for PaaS Event Sourcing with these limitations? If it's Event Hub + snapshotting,...

I want to Test my azure function using the Azure Apps feature to Run/Test mode but it is throwing the '500 internal server error'. I am able to debug the same code in my local environment but when ...

I am currently working on understanding Event Hub along with Azure Function. I have checked out event driven scaling which mentions about the scale controller. But none of the azure documents I ref...

am getting below exception while connecting Event Hub via kafka libraries. Caused by: org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'sasl_auth_bytes': Bytes size -1 ...

Can anyone please figure out what is Consumer Group in Azure Event Hubs. And What is the use of it? I have surfed a lot of sites but I can't get a clear answer.

I could see spark connectors & guidelines for consuming events from Event Hub using Scala in Azure Databricks. But, How can we consume events in event Hub from azure databricks using pySpark? ...

Using the steps documented in structured streaming pyspark, I'm unable to create a dataframe in pyspark from the Azure Event Hub I have set up in order to read the stream data. Error message is: ...

It seems to me that Azure Web PubSub is a combination of both Event Grid and Event Hub using web sockets, instead of HTTP. However, I'm not 100% sure and could not find any articles that have a dir...

I'm receiving events from an EventHub using EventProcessorHost and an IEventProcessor class (call it: MyEventProcessor). I scale this out to two servers by running my EPH on both servers, and havin...

I want to create a Azure function using Powershell which will read data from the Azure Event Hub. Azure function has a template to get the data from the Azure Event hub and but I don't know how to ...

I'm facing an issue related to Azure Event Hubs for Kafka. I have a Kafka consumer processing a message topic name "ABC" that has the below config: ConsumerConfig values: allow.auto.creat...

I'm evaluating the use of Azure Event Hub vs Kafka as a Service Broker. I was hoping I would be able to create two local apps side by side, one that consumes messages using Kafka with the other one...

I find that EventHubProducerClient is not unit test friendly (not mockable) in c# and how do you go about testing it, like SendEventsAsync method?

I have some code that uses the Service Bus Event Data, and I suspect that I need to use the offset property as, currently, my program is (or seems to be) re-running the same Event Hub data over and...

I see this question being asked on a lot of forums but none of them are solving my confusion. This documentation seems to suggest that both offset and sequence number are unique within a partition....

I'm looking for a stable AMQP 1.0 client for NodeJS so that I can consume events from Azure Event Hubs. I have tried using https://github.com/noodlefrenzy/node-amqp10, but it chokes sporadically ...

I'm learning the messaging system and got confused by those terminology. All the messaging system below provides loose coupling between services with different sets of features. queue - FIFO, pu...

I've been learning about Event Hubs and just want to get confirmation or correction on my perspective on Event Hubs? I’m used to leveraging retries, poison messages, at least once delivery and so o...