如何使用EventHub ConsumerGroup上的检查点

Question

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

Answer 1

如果我存储检查点并重新启动应用程序，则应从检查站对不对？

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

关于您在评论中的问题：但是我不清楚什么是检查点和偏移量之间的差异

[检查点，您可以将其视为一种操作或方法，在代码中执行检查点方法（您可以在上面的链接中的我的答案中找到它），然后在Blob存储中，生成了一个json文件。并且在json文件中，它定义了偏移量/序列号，而eph用来确定您可以从何处开始读取事件数据。您可以参考以下json文件的屏幕截图：