kafka 的 max.poll.records 参数

2022-07-26 17:59:12 +08:00
 fatyoung
文档上写着默认是 500 ，意思是单个消费者实例一次性可以从某个分区中取出 1 ～ 500 条消息出来消费，假设我 enable.auto.commit 参数设置为 false ，就是手动提交消费者 offset ，那这 500 条消息的 offset 是否是一次性一起提交？ 如果是一起提交 offset ，这中间有一条消息消费报错了，提交的 offset 应该是多少呢？
822 次点击
所在节点    问与答
1 条回复
IamNotShady
2022-07-26 18:46:57 +08:00
手动提交可以自由控制啊，你可以处理一条就提交一次或者处理 500 条提交一次
"这中间有一条消息消费报错了，提交的 offset 应该是多少呢" 具体看你代码怎么写的 对报错是否做了异常处理

这是一个专为移动设备优化的页面（即为了让你能够在 Google 搜索结果里秒开这个页面），如果你希望参与 V2EX 社区的讨论，你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://www.v2ex.com/t/868849

V2EX 是创意工作者们的社区，是一个分享自己正在做的有趣事物、交流想法，可以遇见新朋友甚至新机会的地方。

V2EX is a community of developers, designers and creative people.

© 2021 V2EX