两个 Azure 事件中心消费者会收到相同的通知吗？

Question

我正在开发一个 Azure IoT Web 应用程序，它使用来自 Azure 事件中心的事件。我定期在测试环境中将 Web 应用程序发布到 Azure，然后我也在自己的机器上以调试模式运行它，当这种情况发生时，基本上有两个 Web 应用程序同时运行，它们是事件中心的消费者。

我想知道一个消费者是否可能会“吞下”通知，以便其他消费者不会收到它。那会很糟糕，我必须为我的调试本地机器设置一个单独的事件中心。

事件中心的两个消费者都会收到所有通知吗？

我没有以任何特殊方式设置事件中心或使用者代码。消费者代码使用Azure.Messaging.EventHubs.EventProcessorClient，其ProcessEventAsync() 如下所示：

async Task ProcessEventHandler(ProcessEventArgs eventArgs)
{
    string deviceId = eventArgs.Data.Properties["deviceId"].ToString();
    string message = Encoding.UTF8.GetString(eventArgs.Data.Body.Span);
    await ProxyMessageToController(deviceId, message);

    
    await eventArgs.UpdateCheckpointAsync(eventArgs.CancellationToken);
}

Answer 1

EventHubProcessorClient 将确保在您创建处理器时指定的使用者组范围内的给定分区只有一个活动读取器。只要读取事件中心的每个EventHubProcessorClient 使用相同的消费者组，它们就不会同时从同一个分区主动读取。

重要的是要知道EventProcessorClient 与其他处理器协调以在它们之间分配负载。当一个处理器从其他处理器“窃取”一个分区的所有权时，您可能会看到一些重叠，其中两者都读取了相同的事件。这种重叠通常是一个非常小的时间窗口，但在某种程度上取决于您的检查点策略。在启动新处理器直到所有分区均等分布之前，您最有可能看到分区所有权发生变化。

另一个需要注意的是，事件中心服务具有至少一次交付保证。尽管事件是一次发布的，但有可能发生重复事件，尽管很少见。