本文介绍了Kaka Auto.offset.Reset查询的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
我的项目使用的是Kafka 0.10.2版本。IAM在消费者中设置enable.Auto.Commit=FALSE和Auto.offset.Reset=LATEST。如果维护后重新启动消费者，则消费者将从第一个偏移量开始再次读取，而不是等待最新的偏移量消息。有什么原因会发生这种情况吗？我是否错误地理解了配置？
我的要求是，使用者不应自动提交，而应仅在主题处于活动状态时读取放入该主题中的新消息。
推荐答案
您没有自动提交并不能保证没有手动提交。
无论如何，auto.offset.reset=latest永远不会将消费者组发送到主题的开头。听起来，无论您使用的是什么Kafka工具/库，它都会自动调用consumer.seekToBeginning。
这篇关于Kaka Auto.offset.Reset查询的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！