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,733 times
Add to favorites
10/27/2014
E-mail Twitter del.icio.us Digg Facebook
Report abuse to Microsoft
Sign in to ask a question

  • Answer the question | Hide
    555-555-0199@example.com
    1 Posts | Last post October 12, 2017
    • Written October 12, 2017 
      555-555-0199@example.com
  • Answer the question | Hide
    Errors when trying to run this sample?
    1 Posts | Last post February 19, 2016
    • Written 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
  • Answer the question | Hide
    Why do you use lock in DemoEventProcessor?
    1 Posts | Last post July 01, 2015
    • Written July 01, 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?
  • Answer the question | Hide
    IEventProcessFactory
    1 Posts | Last post April 01, 2015
    • Written April 01, 2015 
      Is there any reason why this sample cannot be run without the DemoEventProcessFactory and used RegisterEventProcessorAsync() instead?

Thanks,
Rajiv.
  • Answer the question | Hide
    ExceptionReceived - what to do with this?
    1 Posts | Last post September 26, 2014
    • Written 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.
  • Answer the question | Hide
    Azure Storage
    2 Posts | Last post September 19, 2014
    • Written August 01, 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?
    • Written September 19, 2014 
      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.