这是一个创建于 797 天前的主题,其中的信息可能已经有所发展或是发生改变。
文档上写着默认是 500 ,意思是单个消费者实例一次性可以从某个分区中取出 1 ~ 500 条消息出来消费,假设我 enable.auto.commit 参数设置为 false ,就是手动提交消费者 offset ,那这 500 条消息的 offset 是否是一次性一起提交? 如果是一起提交 offset ,这中间有一条消息消费报错了,提交的 offset 应该是多少呢?
1 条回复 • 2022-07-26 18:46:57 +08:00
|
|
1
IamNotShady 2022-07-26 18:46:57 +08:00
手动提交可以自由控制啊,你可以处理一条就提交一次或者处理 500 条提交一次 "这中间有一条消息消费报错了,提交的 offset 应该是多少呢" 具体看你代码怎么写的 对报错是否做了异常处理
|