VB.net中kafka使用者中的vbCommit偏移量



我有一个案例,当消费者将停机时,应该使用偏移量来检查哪条消息将从它离开的地方拾取,而不是从头开始。我在其他语言中找到了很多方法,但在VB.net中我需要同样的方法。如何在VB.net和commit中实现偏移量?

当您在IConsumer实例上调用CommitClose时,它将提交其偏移量(假设为Close启用了自动提交(。

当消费者为相同的GroupId重新启动时,将使用那些提交的偏移。

最新更新