如果auto.offset.reset=earliest但主题没有消息,将设置什么消费者偏移量

我有 Kafka 服务器版本 2.4 并设置log.retention.hours=168(这样主题中的消息将在 7 天后被删除)和auto.offset.reset=earliest(这样如果消费者没有得到最后一次提交offset 那么它应该从头开始处理)。由于我使用的是 Kafka 2.4 版本,因此默认值offsets.retention.minutes=10080(因为我没有在我的应用程序中设置这个属性)。

我的话题数据是:1,2,3,4,5,6,7,8,9,10

关闭消费者之前的当前消费者偏移量:10

结束偏移:10

消费者最后提交的偏移量:10

因此,假设我的消费者在过去 7 天内没有运行,而我在第 8 天启动了消费者。所以我最后一次提交的消费者偏移将过期(由于offsets.retention.minutes=10080属性)并且主题消息也将被删除(由于log.retention.hours=168属性)。

所以想知道现在auto.offset.reset=earliest属性将设置什么消费者偏移量?

以上是如果auto.offset.reset=earliest但主题没有消息,将设置什么消费者偏移量的全部内容。
THE END
分享
二维码
< <上一篇
下一篇>>