我使用合流kafka.net库。如果要遵循以下文档
IConsumer Close()
方法:
提交偏移量,警告组协调器使用者正在退出组,然后释放此使用者使用的所有资源。您应该调用close而不是dispose(或者在调用之前),以确保及时地重新平衡consumergroup
就我而言, autocommit
设置为 false
. 如果处理消息失败,我只想使应用程序崩溃,而不想提交偏移量。
我的问题是:
如果我要用 Close()
方法退出应用程序时(这显然对您的消费者能够重新平衡很重要),它是否会在 autocommit
设置为 false
还是不?或者只有在 autocommit
设置为 true
?
暂无答案!
目前还没有任何答案,快来回答吧!