Scale out Event Processing with Event Hubs

Event Hubs enable you to build applications that require ingesting event streams at very high throughput and low latency. Event Hubs enable you to durably store the events until the required retention period expires. Some of the typical types of applications that require high t

C# (519.6 KB)
 
 
 
 
 
5 Star
(5)
3,511 times
Add to favorites
10/27/2014
E-mail Twitter del.icio.us Digg Facebook
Sign in to ask a question


  • Errors when trying to run this sample?
    1 Posts | Last post February 19, 2016
    • Hi, is there a reason that we should create an EventHub? Can I not use the one I've already created via Azure? As it stands, I'm getting an error from the CreateEventHub() method: The remote server returned an error: (401) Unauthorized. Authorization failed for specified action: Manage. TrackingId:9999d1a7-1bff-4bc2-94f9-34cec47c4694_G47,TimeStamp:2/19/2016 2:42:32 AM
      
      I'm re-using my existing eventHubs and storage keys. Any ideas? Thanks
  • Why do you use lock in DemoEventProcessor?
    1 Posts | Last post June 30, 2015
    • Hi, in ProcessEventsAsync function of DemoEventProcessor.cs, why do you use Interlocked.Increment(ref this.totalMessages); and lock (this), I don't think it is necessary to lock here as these variables are not shared with others. Do you agree?
  • IEventProcessFactory
    1 Posts | Last post April 01, 2015
    • Is there any reason why this sample cannot be run without the DemoEventProcessFactory and used RegisterEventProcessorAsync() instead?
      
      Thanks,
      Rajiv.
  • ExceptionReceived - what to do with this?
    1 Posts | Last post September 26, 2014
    • Hi, I am not sure how to handle this.  The example shows it being logged, and a comment that we could restart the host (presumably by unregistering and re-registering the factory)... but this doesn't seem like such a simple suggestion... There is no guidance on the scenarios in which we should restart the host and which we shouldn't.  Some exceptions seem perfectly normal (i.e. when partitions are balancing across multiple hosts of the same consumer group).  Others I have no idea if I should take some action on...  An example on this would be great.
  • Azure Storage
    2 Posts | Last post September 19, 2014
    • I'm a little confused what I should be putting in the storage account config setting if I don't have local storage tool.  Do you have some more details on on to get what we need for this sample if we create a storage item on Azure portal itself?
    • Sorry for the late response... if you create a storage via azure portal, you will get a connection string over there. Just copy and past, it should work.