azure - 如何使用 EventHub ConsumerGroup 上的检查点

Question

我正在尝试与 Eventhub 和消费者组合作。我的意图是在“n”读取后存储检查点。但我找不到办法做到这一点。使用 nodejs 或 java API 如何执行此操作？如果我存储检查点并重新启动应用程序，它应该从检查点读取，对吗？

标签： azureazure-eventhub

Answer 1

要使用 nodejs 设置检查点，您可以在此处按照我之前的答案进行操作。

如果我存储检查点并重新启动应用程序，它应该从检查点读取，对吗？

是的，因为检查点存储在 azure blob 存储中，所以 eph 知道从哪里开始读取事件数据。

对于您在评论中的问题：但我不清楚检查点和偏移量之间有什么区别

checkpoint，你可以认为它是一个动作或者方法，在代码中执行checkpoint方法后（你可以在上面链接的我的回答中找到它），然后在blob存储中，会生成一个json文件。并且在 json 文件中，它定义了偏移量/序列号，eph 使用它们来确定您可以从哪里开始读取事件数据。你可以参考这个json文件的截图：