我有一个正在运行的 EvenHub，它由 Windows 服务监听。不小心，WindowsService 停止工作了 2 天。如何从 EventHub 停止的地方读取数据？我的 OffSet 设置如下:
processorOptions.InitialOffsetProvider = (partionId) => DateTime.UtcNow;
我尝试再次启动Windows服务，但它从现在开始。
对此有什么想法吗？
最佳答案
您是否曾在 EventProcessor 中调用过 await context.CheckpointAsync(); ？如果没有，您将无法轻松做到这一点。通常，EventProcessor 会跟踪已处理的项目。您可以通过在一段时间后或 EventProcessor 处理多个项目后调用 await context.CheckpointAsync(); 来实现此目的。
使用
processorOptions.InitialOffsetProvider = (partionId) => DateTime.UtcNow;
您基本上告诉EventProcessor忽略之前到达的所有项目。那不是你需要的。删除此调用，如果您在处理代码中调用了 await context.CheckpointAsync();，它将恢复处理尚未处理的项目。如果没有可用的检查点，它将从流的开头开始，具体取决于配置的保留。然后，您将必须手动跳过可能已经处理过的项目。
一些背景阅读:
understanding check pointing in eventhub
https://blogs.msdn.microsoft.com/servicebus/2015/01/16/event-processor-host-best-practices-part-1/
关于azure - 读取指定时间的EventHub数据，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/40013679/