V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
V2EX 提问指南
fatyoung
V2EX  ›  问与答

kafka 的 max.poll.records 参数

  •  
  •   fatyoung · 2022-07-26 17:59:12 +08:00 · 636 次点击
    这是一个创建于 611 天前的主题,其中的信息可能已经有所发展或是发生改变。
    文档上写着默认是 500 ,意思是单个消费者实例一次性可以从某个分区中取出 1 ~ 500 条消息出来消费,假设我 enable.auto.commit 参数设置为 false ,就是手动提交消费者 offset ,那这 500 条消息的 offset 是否是一次性一起提交? 如果是一起提交 offset ,这中间有一条消息消费报错了,提交的 offset 应该是多少呢?
    1 条回复    2022-07-26 18:46:57 +08:00
    IamNotShady
        1
    IamNotShady  
       2022-07-26 18:46:57 +08:00
    手动提交可以自由控制啊,你可以处理一条就提交一次或者处理 500 条提交一次
    "这中间有一条消息消费报错了,提交的 offset 应该是多少呢" 具体看你代码怎么写的 对报错是否做了异常处理
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   我们的愿景   ·   实用小工具   ·   988 人在线   最高记录 6543   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 27ms · UTC 21:58 · PVG 05:58 · LAX 14:58 · JFK 17:58
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.