java - Azure 事件中心偏移

Question

我已经实现了以下链接中的代码，用于从事件中心接收事件。但是假设有 10 个事件，每 5 个事件执行一次检查点。现在，程序在读取第 7 个事件时异常退出，如果我再次重新启动事件处理器主机，则会重新读取事件 (1,2,3,4,6)。请建议我如何再次避免重新阅读和阅读第七次事件？任何例子将不胜感激。谢谢。

https://github.com/Azure/azure-event-hubs/blob/master/samples/Java/src/main/java/com/microsoft/azure/eventhubs/samples/Basic/EventProcessorSample.java

Answer 1

好吧，在事件中心的上下文中，您的工作就是处理可能的消息重复，因为事件中心保证至少一次传递，请参阅

Does Azure Event Hub guarantees at least once delivery?

我们不了解您的情况，因此除了为您构建重复消息检测机制之外，我们无法提出其他建议。例如，在将数据发送到事件中心之前向数据添加唯一 ID，并让处理器根据已处理消息列表检查该 ID。