EventHub consumer
需要在瞬时故障期间处理收到的消息直到成功,如何通过尊重EventHub partition lease expiry
来实现这种无限重试?
这里的业务场景并不重要,但无限重试(by considering partition lease expiry
)的方法是我正在寻找的。
注意:我正在批量读取消息,任何消息的处理都可能遇到暂时的错误,需要重试。因此,使用'offset
'值驱动一些逻辑可能效率不高,但不确定是否有人通过利用偏移值实现了无限重试。
消费者可以对暂时失败无限期地重试,直到请求取消为止。顺便说一下,租约不会过期,因为重试可能比预期的时间长。
请查看API文档以获取更多参考。https://learn.microsoft.com/en-us/dotnet/api/azure.messaging.eventhubs.processor.processeventargs?view=azure-dotnet
CancellationToken
CancellationToken,指示处理器正在请求处理程序停止其活动。如果这个令牌请求取消,那么要么是处理器试图关闭,要么是分区的所有权发生了变化。