0

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

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

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

谢谢。

4

1 回答 1

1

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

于 2017-06-07T15:16:06.087 回答