fatyoung
V2EX  ›  问与答

kafka 的 max.poll.records 参数

  •  
  •   fatyoung · Jul 26, 2022 · 1500 views
    This topic created in 1412 days ago, the information mentioned may be changed or developed.
    文档上写着默认是 500 ,意思是单个消费者实例一次性可以从某个分区中取出 1 ~ 500 条消息出来消费,假设我 enable.auto.commit 参数设置为 false ,就是手动提交消费者 offset ,那这 500 条消息的 offset 是否是一次性一起提交? 如果是一起提交 offset ,这中间有一条消息消费报错了,提交的 offset 应该是多少呢?
    1 replies    2022-07-26 18:46:57 +08:00
    IamNotShady
        1
    IamNotShady  
       Jul 26, 2022
    手动提交可以自由控制啊,你可以处理一条就提交一次或者处理 500 条提交一次
    "这中间有一条消息消费报错了,提交的 offset 应该是多少呢" 具体看你代码怎么写的 对报错是否做了异常处理
    About   ·   Help   ·   Advertise   ·   Blog   ·   API   ·   FAQ   ·   Solana   ·   1036 Online   Highest 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 31ms · UTC 18:09 · PVG 02:09 · LAX 11:09 · JFK 14:09
    ♥ Do have faith in what you're doing.