Orleans EventHub流提供程序

Question

我在一个基于Orleans的项目中使用EventHubStream提供程序。系统运行几分钟后，Orleans在尝试将事件从生产者推送到OnNext时开始抛出QueueCacheMissException。

我试着增加缓存的大小，但只有一小段时间有效。

由于缓存的大小，这是正常行为吗？在这种情况下，我应该取消订阅并重新订阅吗？我曾尝试恢复流，但没有起作用，流处于故障状态...有什么想法吗？

Answer 1

这很可能是因为该服务读取来自eventhub的事件的速度比grains处理它们的速度更快。EventHub可以以每个分区约1k/秒的速率传送事件。最新版本的EventHub流提供程序支持应可防止此问题的背压，但尚未发布。但是，您可以构建自己的nugets。