Kafka消费者重读信息

yzxexxkh  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(360)

我看到一个问题,我的主题中的所有信息都被我的消费者重新阅读。我只有一个消费者,我在开发/测试时打开/关闭它。我注意到,有时在不运行consumer几天后,当我再次打开它时,它会重新读取我的所有消息。
clientid和groupid始终保持不变。我显式地调用commitsync,因为我的enable.auto.commit=false。我确实设置了auto.offset.reset=earlish,但据我所知,只有在服务器上删除了偏移量时才会生效。我使用的是ibmbluemix的messagehub服务,所以可能会自动删除一个偏移量?
有人有什么线索/想法吗?
谢谢。

gstyhher

gstyhher1#

如果24小时内不提交,则会自动删除“是”偏移量。这是Kafka的默认设置,我们没有更改它。

相关问题