Orleans EventHub потоковый провайдер

Question

Я использую провайдера EventHubStream в проекте, основанном на Орлеане. Через несколько минут после запуска системы Орлеан начинает выдавать исключение QueueCacheMissException при попытке отправить событие в OnNext от производителя.

Я пытался увеличить размер кэша, но это помогло только на некоторое время.

Это нормальное поведение из-за размера кеша? В этой ситуации я должен отписаться и подписаться снова? я пытался возобновить поток, но это не сработало, поток был в сбойном состоянии... есть идеи?

Answer 1

Вероятно, что сервис читает события из Eventhub быстрее, чем их обрабатывает зерно. EventHub может доставлять события со скоростью ~1к / сек на раздел. Последняя версия поставщика потока EventHub поддерживает противодавление, которое должно предотвратить эту проблему, но оно не было выпущено. Однако вы можете создавать свои собственные нюгеты.