Spring Kafka自动提交偏移量,即使没有要读取的记录,也会以提交间隔提交相同的偏移量?

问题描述

Spring Kafka 配置如下,

enable.auto.commit = true
auto.commit.interval.ms = 1000

主题几天没有收到消息,所以我的 Kafka 消费者会在提供的时间间隔内一次又一次地提交相同的偏移量?

它是否有助于保持对代理的偏移量写入活动,以便 offsets.retention.minutes = 1440(Kafka 0.10.2 认)属性不会启动并重置偏移量。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)