[苍狼]

0 声望

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

个人动态
  • 半兽人 回复 [苍狼]kafka消费者Java客户端 中 :
    props.setProperty("auto.commit.interval.ms", "1000");
    

    每隔1000ms提交一次。

    3年前
  • [苍狼] 回复 半兽人kafka消费者Java客户端 中 :

    您好,请问下,自动提交offset的话,是什么时机提交呢?是消息一旦到达消费端就会自动commit吗?那如果该条消息被commit了,但业务处理失败了,怎么处理呢?在catch里offset-1,然后手动commit offset吗?

    3年前