kafka设置offset自动提交的时间

识趣 发表于: 2021-09-17   最后更新时间: 2021-09-17 09:43:33   2,737 游览

kafka如何指定offset自动提交的时间呢？

我想精确的控制offset的提交时间。

kafka
发表于 2021-09-17
识趣

kafka自动提交offset主要由以下2个配置控制：

  • enable.auto.commit: 是否开启自动提交offset功能。
  • auto.commit.interval.ms：自动提交offset的时间间隔。

java消费者代码：

Properties props = new Properties();
props.setProperty("enable.auto.commit", "true");      // 开启自动提交
props.setProperty("auto.commit.interval.ms", "1000"); // 每隔1000ms提交一次。

例子可参考：kafka消费者Java客户端

回复
回答于 3年前
半兽人
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。