Kafka 消费者重读消息

Question

我看到了一个问题，即我的主题中的所有消息都会被我的消费者重新阅读。我只有 1 个消费者，我在开发/测试时打开/关闭它。我注意到有时在几天不运行消费者之后，当我突然再次打开它时，它会重新读取我的所有消息。

clientid 和 groupid 始终保持不变。我明确调用 commitSync，因为我的 enable.auto.commit=false。我确实设置了 auto.offset.reset=earliest，但据我了解，只有在服务器上删除了偏移量时才应该启动。我正在使用 IBM Bluemix 的 MessageHub 服务，所以可能会自动删除偏移量？

有没有人有任何线索/想法？

谢谢。

Answer 1

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