java - Azure 事件中心偏移

Question

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

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

Answer 1

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

Azure 事件中心是否保证至少一次交付？

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