[苍狼]

0 声望

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

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

    每隔1000ms提交一次。

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

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

    3年前