我们可以在Kafka经纪人中保留零期吗？

作者: 昵称不能为空
发布时间: 2024-12-30 06:08:16 (18天前)
转自：

2 条回复

0#
回复此人
句号了哦哦 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 当为Kafka主题生成消息时，它将写入磁盘。一旦消息被消费，消息者将提交此消息的偏移量（如果您使用的是高级消费者API），但是，没有功能只删除已消耗的消息（许多消费者可能订阅相同的主题，其中一些可能消耗了该消息，而其他一些可能没有）。 </p> <P> 在您的情况下，我建议设置一个较短的保留期（默认设置为7天），但允许您的消费者使用消息的合理时间。为此，您只需在中配置以下参数 <code> server.properties </code> ： </p> <pre> <code> log.retention.ms=X </code> </pre> <P> 请注意，不保证您的消费者已成功使用已删除的消息。例如，如果将保留期设置为2秒（即 <code> log.retention.ms=2000 </code> ）并且您的消费者崩溃，然后在消费者关闭时发送到主题的每条消息都将丢失。 </p> </DIV>

编辑

登录后才能参与评论