Kaka Auto.offset.Reset查询 [英] Kaka auto.offset.reset query

问题描述

我的项目使用的是Kafka 0.10.2版本。IAM在消费者中设置enable.Auto.Commit=FALSE和Auto.offset.Reset=LATEST。如果维护后重新启动消费者，则消费者将从第一个偏移量开始再次读取，而不是等待最新的偏移量消息。有什么原因会发生这种情况吗？我是否错误地理解了配置？

我的要求是，使用者不应自动提交，而应仅在主题处于活动状态时读取放入该主题中的新消息。

推荐答案

您没有自动提交并不能保证没有手动提交。

无论如何，auto.offset.reset=latest永远不会将消费者组发送到主题的开头。听起来，无论您使用的是什么Kafka工具/库，它都会自动调用consumer.seekToBeginning。

这篇关于Kaka Auto.offset.Reset查询的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！