kafka设置offset自动提交的时间

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

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

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

发表于 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客户端

你的答案

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