Steps:
- Created Azure Event HUB Namespace + Event Hub with 4 partitions
- Also Created Azure Storage Account with Container for CheckPointing
- Created SenterApp to send messages to Azure Event Hub, to check the consistency, I also added the message into my Local DB to check if there is any Duplicates
- Created RecieverAPP with EventProcessor using Register all events with it and used Storage Account for the Checkpointing part Testing Execution Steps
- Started Reciever App to consume all messages to wipe it clean
- Started Client App to push messages + writing to DB after the push
- Stopped Reciever App after some time say 2-3 minutes
- After some time resumed receiver App, so now it will sync up all the messages from the HUB to my resiver App through the event registered.
Which means SenterApp=> 100 messages
RecieverApp => 102 messages
I am sharing the code samples I have used to do demonstrate this issue.