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

kafka 的 max.poll.records 参数

  •  
  •   fatyoung · 2022-07-26 17:59:12 +08:00 · 847 次点击
    这是一个创建于 851 天前的主题,其中的信息可能已经有所发展或是发生改变。
    文档上写着默认是 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   ·   实用小工具   ·   2730 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 23ms · UTC 12:04 · PVG 20:04 · LAX 04:04 · JFK 07:04
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.