azure-eventhub - 奥尔良 EventHub 流提供程序

Question

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

我试图增加缓存的大小，但这只是暂时的。

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

Answer 1

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