CODEWITHSUNDEEP
azure-eventhuborleans
YonatanBM
YonatanBM

Reputation: 46

Orleans EventHub stream provider

I am using the EventHubStream provider in a project based on Orleans. After the system has been running a few minutes Orleans starts throwing a QueueCacheMissException while trying to push an event to OnNext from a producer.

i have tried to increase the size of the cache but that helped only for a while.

Is this a normal behavior due to the size of the cache? In this situation should i unsubscribe and subscribe again? i have tried to resume stream but that didn't work, the stream was in faulted state... any ideas?

Upvotes: 1

Views: 956

Answers (1)

Jason
Jason

Reputation: 21

It is likely that the service is reading events from eventhub faster than grains are processing them. EventHub can deliver events at a rate of ~1k/second per partition. The latest version of the EventHub stream provider supports backpressure that should prevent this problem, but it has not been released. You can however build your own nugets.

Upvotes: 2

Related Questions