我想接收来自eventhub的最新消息,因为之前发送给eventhub的消息太多。我设置了自己的消费组,但似乎只能从早期开始接收消息。
是否有任何方法可以将消息跳过到最新?
如果您在天蓝色eventhub中知道checkpoint,这应该很容易实现。
简而言之,检查点是存储在azure blob存储中的文件,每次您从eventhub读取数据时,偏移量都会记录在检查点中。下次当您使用相同的检查点从eventhub读取数据时,它将从偏移量开始读取。
因此,如果要跳过读取旧数据,可以先创建一个测试接收器项目,例如this,然后设置检查点。然后,下一次在生产中,您可以使用相同的检查点,由于偏移,它将始终跳过旧数据。