合流kafka close()方法

watbbzwu  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(224)

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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题