消费者的数据处理暂停

Question

我们有一个系统将事件推送到 Azure 事件中心，然后系统中的另一个组件从中心处理这些事件。该应用程序是用 node.js 编写的，并使用标准的 Azure EventHub 库。

有时，我们会看到这样的问题：生产者成功地将事件推送到事件中心，但它们没有立即显示给消费者。在一段时间内（通常长达几分钟）没有事件出现，然后所有事件都变得可用，并且消费者必须处理积压的事件。我们已将 maxWaitTimeInSeconds 设置为 1，但是当发生此问题时，processEvents 在相当长的时间内不会被调用。

来自 Azure 的下图显示了事件未得到处理并因此累积时出现的“暂停”。然后消费者迎头赶上。

我们怎样才能防止这种情况发生呢？我们有一个实时系统来显示这些数据，因此我们不能在数据中出现这样的暂停。

Answer 1

通过升级到 azure-event-hubs 包 5.11.3 解决了这个问题。