骑火箭的牛

0 声望

这家伙太懒，什么都没留下

个人动态
  • 骑火箭的牛 回复 渊虹 在 kafka消费端手动提交ack失败 中 ：

    我这边也出现了相同的场景。。。应该也是这个原因

    1年前
  • 赞了 骑火箭的牛 在 kafka消费端手动提交ack失败 的评论! 
    //设置提交偏移量的方式， MANUAL_IMMEDIATE 表示消费一条提交一次；MANUAL表示批量提交一次
factory.getContainerProperties().setAckMode((ContainerProperties.AckMode.MANUAL_IMMEDIATE));

    MANUAL_IMMEDIATE 这个提交的方式虽然是消费一次提交一次 但是kafka每一批都会拉取max.poll.records（默认500条数据） 比如说在消费第300条数据是手动提交的时候 （1-300条数据）消费的总时长超过了max.poll.interval.ms 就会被踢出消费者组

    1年前